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