From 351acb7875cff4da0a4e169b3639439ebdf1aa51 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C4=99drzej=20Stuczy=C5=84ski?= Date: Thu, 18 Sep 2025 10:57:01 +0100 Subject: [PATCH] expose cancelled --- sdk/rust/nym-sdk/src/mixnet/native_client.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/sdk/rust/nym-sdk/src/mixnet/native_client.rs b/sdk/rust/nym-sdk/src/mixnet/native_client.rs index c9495680b2..9050ff45a1 100644 --- a/sdk/rust/nym-sdk/src/mixnet/native_client.rs +++ b/sdk/rust/nym-sdk/src/mixnet/native_client.rs @@ -25,6 +25,7 @@ use std::sync::Arc; use std::task::{Context, Poll}; use tokio::sync::RwLockReadGuard; use tokio_util::sync::CancellationToken; +use tokio_util::sync::WaitForCancellationFutureOwned; /// Client connected to the Nym mixnet. pub struct MixnetClient { @@ -273,6 +274,12 @@ impl MixnetClient { } } } + + pub fn cancelled(&self) -> WaitForCancellationFutureOwned { + self.shutdown_handle + .clone_shutdown_token() + .cancelled_owned() + } } #[derive(Clone)]