Merge pull request #1148 from derekdreery/spawn_local

Spawn local

crates/futures/src/lib.rs

@@ -377,3 +377,22 @@ fn _future_to_promise(future: Box<Future<Item = JsValue, Error = JsValue>>) -> P
         }
     }
 }
+
+/// Converts a Rust `Future` on a local task queue.
+///
+/// The `future` provided must adhere to `'static` because it'll be scheduled
+/// to run in the background and cannot contain any stack references.
+///
+/// # Panics
+///
+/// This function has the same panic behavior as `future_to_promise`.
+pub fn spawn_local<F>(future: F)
+where
+    F: Future<Item=(), Error=()> + 'static,
+{
+    future_to_promise(
+        future
+            .map(|()| JsValue::undefined())
+            .map_err(|()| JsValue::undefined()),
+    );
+}

crates/futures/tests/tests.rs

@@ -9,7 +9,7 @@ extern crate wasm_bindgen_test;
 use futures::unsync::oneshot;
 use futures::Future;
 use wasm_bindgen::prelude::*;
-use wasm_bindgen_futures::{future_to_promise, JsFuture};
+use wasm_bindgen_futures::{future_to_promise, spawn_local, JsFuture};
 use wasm_bindgen_test::*;
 
 #[wasm_bindgen_test(async)]
@@ -68,3 +68,21 @@ fn oneshot_works() -> impl Future<Item = (), Error = JsValue> {
     closure.forget();
     rx.then(|_| Ok(()))
 }
+
+#[wasm_bindgen_test(async)]
+fn spawn_local_runs() -> impl Future<Item = (), Error = JsValue> {
+    let (tx, rx) = oneshot::channel::<u32>();
+    let fn_box = Box::new(move || {
+        tx.send(42).unwrap();
+    });
+    spawn_local(futures::future::ok::<(), ()>(()).map(|_| {
+        fn_box();
+    }));
+    rx.then(|val| {
+        if val == Ok(42) {
+            Ok(())
+        } else {
+            Err(JsValue::undefined())
+        }
+    })
+}