neon

Function set_global_executor

Source
pub fn set_global_executor<R>(cx: &mut Cx<'_>, runtime: R) -> Result<(), R>
where R: Runtime,
Available on crate features napi-6 and futures only.
Expand description

Register a Future executor runtime globally to the addon.

Returns Ok(()) if a global executor has not been set and Err(runtime) if it has.

If the tokio feature flag is enabled and the addon does not provide a #[neon::main] function, a multithreaded tokio runtime will be automatically registered.

Note: Each instance of the addon will have its own runtime. It is recommended to initialize the async runtime once in a process global and share it across instances.

use once_cell::sync::OnceCell;
use tokio::runtime::Runtime;

static RUNTIME: OnceCell<Runtime> = OnceCell::new();

#[neon::main]
fn main(mut cx: ModuleContext) -> NeonResult<()> {
    let runtime = RUNTIME
        .get_or_try_init(Runtime::new)
        .or_else(|err| cx.throw_error(err.to_string()))?;

    let _ = neon::set_global_executor(&mut cx, runtime);

    Ok(())
}