Async code linked to artwrap

Cargo.toml

@@ -11,15 +11,10 @@ homepage = "https://github.com/martin-kolarik/futures-signals-ext"
 [features]
 default = ["option", "spawn-local"]
 option = []
-spawn = ["async-global-executor"]
-spawn-local = ["async-global-executor", "wasm-bindgen-futures"]
+spawn = []
+spawn-local = []
 
 [dependencies]
+artwrap = { git = "https://github.com/martin-kolarik/artwrap.git" }
 futures-signals = { version = "^0.3", default-features = false }
 pin-project-lite = { version = "^0.2" }
-
-[target.'cfg(not(target_os = "unknown"))'.dependencies]
-async-global-executor = { version = "^2.4", default-features = false, optional = true }
-
-[target.'cfg(target_arch = "wasm32")'.dependencies]
-wasm-bindgen-futures = { version = "^0.4", optional = true }

src/futures_signals_spawn.rs

@@ -75,8 +75,7 @@ mod os {
             F: Fn(A) -> W + Send + 'static,
             W: Future<Output = ()> + Send + 'static,
         {
-            async_global_executor::init();
-            async_global_executor::spawn(self.for_each(move |new| f(new))).detach();
+            artwrap::spawn(self.for_each(move |new| f(new)));
         }
 
         #[cfg(feature = "spawn-local")]
@@ -96,8 +95,7 @@ mod os {
             F: Fn(A) -> W + 'static,
             W: Future<Output = ()> + 'static,
         {
-            async_global_executor::init();
-            async_global_executor::spawn_local(self.for_each(move |new| f(new))).detach();
+            artwrap::spawn_local(self.for_each(move |new| f(new)));
         }
     }
 
@@ -111,25 +109,21 @@ mod os {
             Self: Send,
             F: Fn(VecDiff<A>) + Send + 'static,
         {
-            async_global_executor::init();
-            async_global_executor::spawn(self.for_each(move |new| {
+            artwrap::spawn(self.for_each(move |new| {
                 f(new);
                 ready(())
-            }))
-            .detach();
+            }));
         }
 
         #[cfg(feature = "spawn-local")]
         fn spawn_local<F>(self, f: F)
         where
             F: Fn(VecDiff<A>) + 'static,
         {
-            async_global_executor::init();
-            async_global_executor::spawn_local(self.for_each(move |new| {
+            artwrap::spawn_local(self.for_each(move |new| {
                 f(new);
                 ready(())
-            }))
-            .detach();
+            }));
         }
     }
 }
@@ -185,7 +179,7 @@ mod wasm {
             F: Fn(A) -> W + 'static,
             W: Future<Output = ()> + 'static,
         {
-            wasm_bindgen_futures::spawn_local(self.for_each(move |new| f(new)));
+            artwrap::spawn_local(self.for_each(move |new| f(new)));
         }
     }
 
@@ -207,7 +201,7 @@ mod wasm {
         where
             F: Fn(VecDiff<A>) + 'static,
         {
-            wasm_bindgen_futures::spawn_local(self.for_each(move |new| {
+            artwrap::spawn_local(self.for_each(move |new| {
                 f(new);
                 ready(())
             }));