sdk: add abortable thread

crates/nostr-sdk/src/util/thread/mod.rs

@@ -5,6 +5,7 @@
 
 use std::time::Duration;
 
+use nostr_sdk_net::futures_util::stream::{AbortHandle, Abortable};
 use nostr_sdk_net::futures_util::Future;
 #[cfg(feature = "blocking")]
 use tokio::runtime::{Builder, Runtime};
@@ -92,6 +93,29 @@ where
  Some(JoinHandle::Wasm(handle))
 }
 
+/// Spawn abortable thread
+#[cfg(not(target_arch = "wasm32"))]
+pub fn abortable<T>(future: T) -> AbortHandle
+where
+ T: Future + Send + 'static,
+ T::Output: Send + 'static,
+{
+ let (abort_handle, abort_registration) = AbortHandle::new_pair();
+ spawn(Abortable::new(future, abort_registration));
+ abort_handle
+}
+
+/// Spawn abortable thread
+#[cfg(target_arch = "wasm32")]
+pub fn abortable<T>(future: T) -> AbortHandle
+where
+ T: Future + 'static,
+{
+ let (abort_handle, abort_registration) = AbortHandle::new_pair();
+ spawn(Abortable::new(future, abort_registration));
+ abort_handle
+}
+
 /// Sleep
 pub async fn sleep(duration: Duration) {
  #[cfg(not(target_arch = "wasm32"))]