Struct SteerInbox 

pub struct SteerInbox { /* private fields */ }

Mid-run steering inbox: ParentFrame::Message texts arriving while a run is active. Executors that support in-band steering admit them at a safe point (the engine’s round boundary); others may simply ignore the inbox.

Implementations

impl SteerInbox

pub fn channel() -> (UnboundedSender<SteerMessage>, Self)

Create a sender + inbox pair (the transport holds the sender).

pub fn disconnected() -> Self

An already-closed inbox (for tests / executors that don’t steer).

pub async fn recv(&mut self) -> Option<String>

Next steering message, or None once the run’s sender is gone.

pub async fn wait_initial_release( &mut self, request: &InitialInputReleaseRequest, cancel: &CancellationToken, events: &EventSink, ) -> Result<DateTime<Utc>, String>

Wait before SDK admission. Exact unexpired replies from this inbox’s completed barriers are duplicates; every other mismatched control fails.

pub async fn recv_message(&mut self) -> Option<SteerMessage>

Receive the typed steering value. Runtime-backed workers use this path so SessionInbox envelopes never collapse into ad-hoc text.