plugin_mqtt: Change mainloop signature to use CancellationToken

Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>

1 files changed, 2 insertions, 2 deletions

diff --git a/plugins/plugin_mqtt/src/plugin.rs b/plugins/plugin_mqtt/src/plugin.rs
index cf3e480e..89e2781a 100644
--- a/plugins/plugin_mqtt/src/plugin.rs
+++ b/plugins/plugin_mqtt/src/plugin.rs
@@ -111,7 +111,7 @@ struct State {
 
 async fn mqtt_main(
     mut state: State,
-    mut stopper: tokio::sync::oneshot::Receiver<()>,
+    stopper: tedge_api::CancellationToken,
 ) -> Result<(), PluginError> {
     use futures::stream::StreamExt;
 
@@ -153,7 +153,7 @@ async fn mqtt_main(
                 }
             }
 
-            _cancel = &mut stopper => {
+            _cancel = stopper.cancelled() => {
                 break
             }
         }