From dc660decee41c8f43945f5f0bc2fe8f5f7ffb41a Mon Sep 17 00:00:00 2001 From: Klesti Selimaj Date: Tue, 28 Jul 2026 03:34:42 +0200 Subject: [PATCH] Removed unnecessary clones on strategy engine --- src/engine/engine/plugin.rs | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/src/engine/engine/plugin.rs b/src/engine/engine/plugin.rs index f620822..990e18f 100644 --- a/src/engine/engine/plugin.rs +++ b/src/engine/engine/plugin.rs @@ -65,13 +65,12 @@ impl StrategyEngine { .upgrade() .expect("Failed to upgrade engine (StrategyEngine)"); - let strategy = self.strategy.clone(); - let risk = self.risk.clone(); - - strategy.send(&StrategyEngineMessage::Initialize).await?; + self.strategy + .send(&StrategyEngineMessage::Initialize) + .await?; loop { - match strategy.recv().await? { + match self.strategy.recv().await? { None => {} Some(StrategyMessage::GetWatchList) => { @@ -88,7 +87,7 @@ impl StrategyEngine { } Some(StrategyMessage::Signal(signal)) => { - risk.send(&RiskEngineMessage::Signal(signal)).await?; + self.risk.send(&RiskEngineMessage::Signal(signal)).await?; } Some(StrategyMessage::Subscribe(subscription)) => { @@ -152,12 +151,10 @@ impl StrategyEngine { .upgrade() .expect("Failed to upgrade engine (StrategyEngine)"); - let risk = self.risk.clone(); - - risk.send(&RiskEngineMessage::Initialize).await?; + self.risk.send(&RiskEngineMessage::Initialize).await?; loop { - match risk.recv().await? { + match self.risk.recv().await? { None => {} Some(RiskMessage::GetWatchList) => {