neon/macro_internal/
futures.rs

1use std::future::Future;
2
3use crate::{
4    context::{Context, Cx, TaskContext},
5    result::JsResult,
6    types::JsValue,
7};
8
9pub fn spawn<'cx, F, S>(cx: &mut Cx<'cx>, fut: F, settle: S) -> JsResult<'cx, JsValue>
10where
11    F: Future + Send + 'static,
12    F::Output: Send,
13    S: FnOnce(TaskContext, F::Output) -> JsResult<JsValue> + Send + 'static,
14{
15    let rt = match crate::executor::RUNTIME.get(cx) {
16        Some(rt) => rt,
17        None => return cx.throw_error("must initialize with neon::set_global_executor"),
18    };
19
20    let ch = cx.channel();
21    let (d, promise) = cx.promise();
22
23    rt.spawn(Box::pin(async move {
24        let res = fut.await;
25        let _ = d.try_settle_with(&ch, move |cx| settle(cx, res));
26    }));
27
28    Ok(promise.upcast())
29}

neon/macro_internal/futures.rs

neon/macro_internal/
futures.rs