Struct neon::event::TaskBuilder
source · pub struct TaskBuilder<'cx, C, E> { /* private fields */ }
Expand description
Node asynchronous task builder
fn greet(mut cx: FunctionContext) -> JsResult<JsPromise> {
let name = cx.argument::<JsString>(0)?.value(&mut cx);
let promise = cx
.task(move || format!("Hello, {}!", name))
.promise(move |mut cx, greeting| Ok(cx.string(greeting)));
Ok(promise)
}
Implementations§
source§impl<'a: 'cx, 'cx, C, O, E> TaskBuilder<'cx, C, E>where
C: Context<'a>,
O: Send + 'static,
E: FnOnce() -> O + Send + 'static,
impl<'a: 'cx, 'cx, C, O, E> TaskBuilder<'cx, C, E>where C: Context<'a>, O: Send + 'static, E: FnOnce() -> O + Send + 'static,
sourcepub fn new(cx: &'cx mut C, execute: E) -> Self
pub fn new(cx: &'cx mut C, execute: E) -> Self
Construct a new task builder from an execute
callback that can be
scheduled to execute on the Node worker pool
sourcepub fn and_then<F>(self, complete: F)where
F: FnOnce(TaskContext<'_>, O) -> NeonResult<()> + 'static,
pub fn and_then<F>(self, complete: F)where F: FnOnce(TaskContext<'_>, O) -> NeonResult<()> + 'static,
Schedules a task to execute on the Node worker pool, executing the
complete
callback on the JavaScript main thread with the result
of the execute
callback
sourcepub fn promise<V, F>(self, complete: F) -> Handle<'a, JsPromise>where
V: Value,
F: FnOnce(TaskContext<'_>, O) -> JsResult<'_, V> + 'static,
pub fn promise<V, F>(self, complete: F) -> Handle<'a, JsPromise>where V: Value, F: FnOnce(TaskContext<'_>, O) -> JsResult<'_, V> + 'static,
Schedules a task to execute on the Node worker pool and returns a
promise that is resolved with the value from the complete
callback.
The complete
callback will execute on the JavaScript main thread and
is passed the return value from execute
. If the complete
callback
throws, the promise will be rejected with the exception