pub fn new_from_core(worker: Arc<dyn CoreWorker>, task_queue: impl Into<String>) -> Self {
        Self {
            common: CommonWorker {
                worker,
                task_queue: task_queue.into(),
                worker_interceptor: None,
            },
            workflow_half: WorkflowHalf {
                workflows: Default::default(),
                workflow_fns: Default::default(),
                join_handles: FuturesUnordered::new(),
            },
            activity_half: ActivityHalf {
                activity_fns: Default::default(),
                task_tokens_to_cancels: Default::default(),
            },
        }
    }
/// Create a new rust worker from a core worker
Create a new rust worker from a core worker
Create a new rust worker from a core worker
pub fn new_from_core(worker: Arc<dyn CoreWorker>, task_queue: impl Into<String>) -> Self {
        Self {
            common: CommonWorker {
                worker,
                task_queue: task_queue.into(),
                worker_interceptor: None,
            },
            workflow_half: WorkflowHalf {
                workflows: Default::default(),
                workflow_fns: Default::default(),
                join_handles: FuturesUnordered::new(),
            },
            activity_half: ActivityHalf {
                activity_fns: Default::default(),
                task_tokens_to_cancels: Default::default(),
            },
        }
    }
pub fn new_from_core ( worker : Arc < dyn CoreWorker > , task_queue : impl Into < String > ) -> Self { Self { common : CommonWorker { worker , task_queue : task_queue . into ( ) , worker_interceptor : None , } , workflow_half : WorkflowHalf { workflows : Default :: default ( ) , workflow_fns : Default :: default ( ) , join_handles : FuturesUnordered :: new ( ) , } , activity_half : ActivityHalf { activity_fns : Default :: default ( ) , task_tokens_to_cancels : Default :: default ( ) , } , } }
Create a new rust worker from a core worker
Create a new rust worker from a core worker
worker
Arc<dyn CoreWorker>
task_queue
impl Into<String>
worker
Arc<dyn CoreWorker>
task_queue
impl Into<String>