Function zng_task::ipc::run_worker

source ·
pub fn run_worker<I, O, F>(
    worker_name: impl Into<Txt>,
    handler: impl Fn(RequestArgs<I>) -> F + Send + Sync + 'static
)
where I: IpcValue, O: IpcValue, F: Future<Output = O> + Send + Sync + 'static,
Expand description

If the process was started by a Worker runs the worker loop and never returns. If not started as worker does nothing.

The handler is called for each work request.