Struct SteeringInbox 

pub struct SteeringInbox(/* private fields */);

Implementations

impl SteeringInbox

pub fn is_open(&self) -> bool

pub fn has_pending(&self) -> bool

pub fn enter<'a>(self: &Arc<Self>, sink: &'a EventSink) -> SteeringScope<'a>

pub fn enqueue( &self, text: String, persist: impl FnOnce() -> Result<(), String>, ) -> Result<(), String>

Persist before acknowledgement. Holding the inbox lock makes admission atomic with loop completion, and a failed write never queues guidance.

pub fn take(&self) -> Vec<String>

Trait Implementations

impl Debug for SteeringInbox

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SteeringInbox

fn default() -> Self

Returns the “default value” for a type.