more tidy up

helium · Jul 20, 2023 · 9c3b99f · 9c3b99f
1 parent aaf6cf4
commit 9c3b99f
Show file tree

Hide file tree

Showing 10 changed files with 21 additions and 21 deletions.
diff --git a/file_store/src/file_info_poller.rs b/file_store/src/file_info_poller.rs
@@ -79,9 +79,9 @@ where
 {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        let handle = tokio::spawn(self.run(shutdown_listener));
+        let handle = tokio::spawn(self.run(shutdown));
 
         Box::pin(
             handle

diff --git a/iot_verifier/src/entropy_loader.rs b/iot_verifier/src/entropy_loader.rs
@@ -22,9 +22,9 @@ pub enum NewLoaderError {
 impl ManagedTask for EntropyLoader {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/gateway_updater.rs b/iot_verifier/src/gateway_updater.rs
@@ -34,9 +34,9 @@ pub enum GatewayUpdaterError {
 impl ManagedTask for GatewayUpdater {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/loader.rs b/iot_verifier/src/loader.rs
@@ -60,9 +60,9 @@ pub enum ValidGatewayResult {
 impl ManagedTask for Loader {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/packet_loader.rs b/iot_verifier/src/packet_loader.rs
@@ -30,9 +30,9 @@ pub enum NewLoaderError {
 impl ManagedTask for PacketLoader {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/purger.rs b/iot_verifier/src/purger.rs
@@ -50,9 +50,9 @@ pub struct NewPurgerError(#[from] db_store::Error);
 impl ManagedTask for Purger {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/rewarder.rs b/iot_verifier/src/rewarder.rs
@@ -29,9 +29,9 @@ pub struct Rewarder {
 impl ManagedTask for Rewarder {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/runner.rs b/iot_verifier/src/runner.rs
@@ -65,9 +65,9 @@ pub enum FilterStatus {
 impl ManagedTask for Runner {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/iot_verifier/src/tx_scaler.rs b/iot_verifier/src/tx_scaler.rs
@@ -33,9 +33,9 @@ pub enum TxScalerError {
 impl ManagedTask for Server {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self.run(shutdown_listener))
+        Box::pin(self.run(shutdown))
     }
 }
 

diff --git a/task_manager/src/lib.rs b/task_manager/src/lib.rs
@@ -9,7 +9,7 @@ use tokio::signal;
 pub trait ManagedTask {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>>;
 }
 
@@ -44,9 +44,9 @@ where
 {
     fn start_task(
         self: Box<Self>,
-        shutdown_listener: triggered::Listener,
+        shutdown: triggered::Listener,
     ) -> LocalBoxFuture<'static, anyhow::Result<()>> {
-        Box::pin(self(shutdown_listener))
+        Box::pin(self(shutdown))
     }
 }