Struct WorkerJoinHandler 

pub struct WorkerJoinHandler {
    pub worker_id: WorkerId,
    pub cancel: CancellationToken,
    pub completion: Receiver<Result<(), WorkerError>>,
}

Handler for a Worker’s async completion signal. A building block; it does not implement Worker itself. Holds the (worker_id, cancel token, oneshot receiver) triple and is embedded by every per-kind Worker (AgentBlockWorker / LuaWorker / RustFnWorker / ProcessWorker / OperatorWorker).

“The Worker that actually does the work” and “the mechanism that waits for its async completion” are two different concepts. This struct is dedicated to the latter; the former is expressed by per-kind Worker structs — one type per AgentKind, each hiding its kind-specific state (SDK quirks, VM state, child-process handles, etc.) inside itself.

Fields

worker_id: WorkerId

Identity of the worker this handler belongs to.

cancel: CancellationToken

Cancellation token shared with the running task; cloned out via Worker::cancel_token.

completion: Receiver<Result<(), WorkerError>>

Receiver side of the oneshot channel the spawned task completes through. Consumed by await_completion.

Implementations

impl WorkerJoinHandler

pub async fn await_completion(self) -> Result<(), WorkerError>

Shared helper that receives the join async signal. This is the canonical path called from every per-kind Worker’s Worker::join implementation.

Trait Implementations

impl From<WorkerJoinHandler> for LuaWorker

fn from(handler: WorkerJoinHandler) -> Self

Converts to this type from the input type.

impl From<WorkerJoinHandler> for RustFnWorker

fn from(handler: WorkerJoinHandler) -> Self

Converts to this type from the input type.

impl From<WorkerJoinHandler> for AgentBlockWorker

fn from(handler: WorkerJoinHandler) -> Self

Converts to this type from the input type.

impl From<WorkerJoinHandler> for MiddlewareWorker

fn from(handler: WorkerJoinHandler) -> Self

Converts to this type from the input type.