Struct WorkerChannelBridge 

pub struct WorkerChannelBridge {
    pub worker_id: WorkerId,
    pub page_to_worker_tx: Sender<StructuredClonePayload>,
    pub worker_to_page_rx: Receiver<WorkerStructuredMessage>,
    /* private fields */
}

Bidirectional channel bridge for a single Worker’s postMessage channel.

Holds the mpsc channel endpoints for page↔worker communication. The bridge does NOT hold JSObject references — only channel endpoints and serialized data. This is safe to store across threads.

SPEC DF-WK-4: page→worker (sender → receiver in worker thread) SPEC DF-WK-5: worker→page (sender in worker thread → receiver here)

@trace REQ-BRW-004 [entity:Worker] [entity:DedicatedWorkerGlobalScope] [criterion:6] DF-WK-4 / DF-WK-5

Fields

worker_id: WorkerId

Worker ID this bridge belongs to.

page_to_worker_tx: Sender<StructuredClonePayload>

Sender for page→worker messages (DF-WK-4: worker.postMessage(msg)). Structured-clone serialized bytes sent through this channel. @trace REQ-BRW-004 [entity:Worker] DF-WK-4

worker_to_page_rx: Receiver<WorkerStructuredMessage>

Receiver for worker→page messages (DF-WK-5: self.postMessage(msg)). @trace REQ-BRW-004 [entity:DedicatedWorkerGlobalScope] DF-WK-5

Implementations

impl WorkerChannelBridge

pub fn new(worker_id: WorkerId) -> (Self, WorkerChannelEndpoints)

Create a new channel bridge for the given Worker.

Returns the bridge (kept by bao_browser) and a WorkerChannelEndpoints struct that should be sent to the worker thread for its use.

@trace REQ-BRW-004 [entity:Worker] [criterion:6] DF-WK-4 / DF-WK-5

pub fn post_message_to_worker( &self, payload: StructuredClonePayload, ) -> Result<(), SendError<StructuredClonePayload>>

Post a message from the page to this Worker (DF-WK-4).

Sends structured-clone serialized bytes through the channel. Returns Err if the worker thread has exited (channel closed).

@trace REQ-BRW-004 [entity:Worker] [criterion:6] DF-WK-4

pub fn try_recv_from_worker( &self, ) -> Result<Option<WorkerStructuredMessage>, ()>

Try to receive a message from this Worker (DF-WK-5).

Non-blocking: returns Ok(Some(msg)) if a message is available, Ok(None) if the channel is empty, Err if the worker has exited.

@trace REQ-BRW-004 [entity:DedicatedWorkerGlobalScope] [criterion:6] DF-WK-5

pub fn drain_worker_messages(&self) -> WorkerDrainResult

Drain all pending worker→page messages (DF-WK-5).

Called during spin_event_loop to process all queued messages from workers. Returns a WorkerDrainResult that includes both the drained messages and whether the worker has disconnected.

When disconnected is true, the worker thread has exited and the caller should trigger cleanup (reap terminated workers).

@trace REQ-BRW-004 [entity:DedicatedWorkerGlobalScope] DF-WK-5 @trace REQ-BRW-004 [criterion:18] crash-safe teardown detection