From cafb50cce33708c934092ccd2ec4e29ba325894a Mon Sep 17 00:00:00 2001 From: Alexey Velikiy Date: Mon, 3 Jan 2022 14:21:50 +0300 Subject: [PATCH] small refactorign --- server/src/services/analytic_service/analytic_service.rs | 2 +- server/src/services/analytic_service/detection_runner.rs | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/services/analytic_service/analytic_service.rs b/server/src/services/analytic_service/analytic_service.rs index 94fc5e6..94824da 100644 --- a/server/src/services/analytic_service/analytic_service.rs +++ b/server/src/services/analytic_service/analytic_service.rs @@ -137,7 +137,7 @@ impl AnalyticService { }; let tx = self.tx.clone(); let au = self.analytic_unit.as_ref().unwrap().clone(); - let dr = DetectionRunner::new(self.metric_service.clone(), tx, drcfg, au); + let dr = DetectionRunner::new(tx,self.metric_service.clone(), drcfg, au); self.detection_runner = Some(dr); self.detection_runner.as_mut().unwrap().run(from); diff --git a/server/src/services/analytic_service/detection_runner.rs b/server/src/services/analytic_service/detection_runner.rs index f5362dc..50eb7b3 100644 --- a/server/src/services/analytic_service/detection_runner.rs +++ b/server/src/services/analytic_service/detection_runner.rs @@ -9,8 +9,8 @@ use tokio::time::{sleep, Duration}; pub struct DetectionRunner { - metric_service: MetricService, tx: mpsc::Sender, + metric_service: MetricService, config: DetectionRunnerConfig, analytic_unit: AnalyticUnitRF, running_handler: Option>, @@ -18,8 +18,8 @@ pub struct DetectionRunner { impl DetectionRunner { pub fn new( - metric_service: MetricService, tx: mpsc::Sender, + metric_service: MetricService, config: DetectionRunnerConfig, analytic_unit: AnalyticUnitRF, ) -> DetectionRunner {