worker_wrapper

Function worker_wrapper 

Source
pub async fn worker_wrapper<Data, Comp, Ctx>(
    worker_id: WorkerId,
    ctx: Arc<Ctx>,
    storage: Arc<dyn TaskQueue<Data> + Send + Sync>,
    computation: Arc<Comp>,
    commands: Receiver<WorkerCommand>,
    terminate: Receiver<()>,
    worker_options: WorkerOptions,
)
where Data: Debug + Clone + Serialize + DeserializeOwned + Send + Sync + 'static, Comp: Computation<Data, Ctx> + Send + Sync + 'static, Ctx: Configurable + Send + Sync + 'static,
Expand description

This wrapper used to create new Worker setup internal logging and handle comminications with worker