mirror of
https://github.com/fluencelabs/wasm-bindgen
synced 2025-03-28 07:51:07 +00:00
Add naive spawn_local implementation + tests
This is just a naive implementation. It seems it can be improved using a custom task queue, but that can be in a separate PR.
This commit is contained in:
parent
1758c8d5af
commit
c849ef3cf4
@ -377,3 +377,15 @@ fn _future_to_promise(future: Box<Future<Item = JsValue, Error = JsValue>>) -> P
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Spawns a future.
|
||||||
|
pub fn spawn_local<F>(future: F)
|
||||||
|
where
|
||||||
|
F: Future<Item = (), Error = ()> + 'static,
|
||||||
|
{
|
||||||
|
future_to_promise(
|
||||||
|
future
|
||||||
|
.map(|_| JsValue::undefined())
|
||||||
|
.map_err(|_| JsValue::undefined()),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
@ -9,7 +9,7 @@ extern crate wasm_bindgen_test;
|
|||||||
use futures::unsync::oneshot;
|
use futures::unsync::oneshot;
|
||||||
use futures::Future;
|
use futures::Future;
|
||||||
use wasm_bindgen::prelude::*;
|
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::*;
|
use wasm_bindgen_test::*;
|
||||||
|
|
||||||
#[wasm_bindgen_test(async)]
|
#[wasm_bindgen_test(async)]
|
||||||
@ -68,3 +68,21 @@ fn oneshot_works() -> impl Future<Item = (), Error = JsValue> {
|
|||||||
closure.forget();
|
closure.forget();
|
||||||
rx.then(|_| Ok(()))
|
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())
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user