Struct EventSink 

pub struct EventSink { /* private fields */ }

Sink an executor emits events into; the transport forwards each as a ChildFrame::Event.

Implementations

impl EventSink

pub fn channel() -> (Self, UnboundedReceiver<Value>)

Create a sink + the receiver the transport pumps to the wire.

pub fn channel_with_control() -> (Self, UnboundedReceiver<Value>, UnboundedReceiver<ExecutorControl>)

Create a sink with a control channel for protocol-level confirmations.

pub fn with_host_bridge(self, bridge: HostBridge) -> Self

Attach a host-callback bridge (the transport wires this for real runs).

pub fn host(&self) -> Option<&HostBridge>

The host-callback bridge, if this run was wired with one.

pub fn emit(&self, event: Value)

Emit one event (serialized agent event). Dropped silently if the peer is gone.

pub fn confirm_session_message( &self, confirmation: SessionMessageAdmissionConfirmation, )

Confirm a forwarded SessionInbox message only after the executor has observed its durable local admitted receipt.

Trait Implementations

impl Clone for EventSink

fn clone(&self) -> EventSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.