expose cancelled

Author: jstuczyn

sdk/rust/nym-sdk/src/mixnet/native_client.rs

@@ -24,6 +24,7 @@ use std::pin::Pin;
 use std::sync::Arc;
 use std::task::{Context, Poll};
 use tokio::sync::RwLockReadGuard;
+use tokio_util::sync::WaitForCancellationFutureOwned;
 
 /// Client connected to the Nym mixnet.
 pub struct MixnetClient {
@@ -267,6 +268,12 @@ impl MixnetClient {
             }
         }
     }
+
+    pub fn cancelled(&self) -> WaitForCancellationFutureOwned {
+        self.shutdown_handle
+            .clone_shutdown_token()
+            .cancelled_owned()
+    }
 }
 
 #[derive(Clone)]