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 const EVENT_CAPACITY: usize = 256

pub const CONTROL_CAPACITY: usize = 32

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

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

pub fn channel_with_control() -> (Self, Receiver<Value>, Receiver<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 async fn emit(&self, event: Value)

Emit one event with bounded producer backpressure. Transport QoS still decides whether a sequenced live batch can be dropped; durable events cannot accumulate without bound ahead of that transport or be lost here.

pub async fn request_initial_release( &self, request: InitialInputReleaseRequest, ) -> Result<(), String>

pub async 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) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.