Struct Outbox 

pub struct Outbox<T> { /* private fields */ }

A node’s writer on one of its output queues.

Implementations

impl<T> Outbox<T>

pub fn cx(&self) -> &Rc<NodeCx>

The node context the outbox charges.

pub fn has_room(&self) -> bool

Whether the queue would take an item right now.

pub fn emit( &mut self, at: Provenance, payload: T, ) -> impl Future<Output = ()> + '_

Sends an event, waiting for room in the queue.

pub fn gap(&mut self, range: TickRange) -> impl Future<Output = ()> + '_

Tells the readers that range is missing.

pub fn progress(&mut self, tick: Tick) -> impl Future<Output = ()> + '_

Tells the readers that nothing more comes before tick.

pub fn end(&mut self, tick: Tick) -> impl Future<Output = ()> + '_

Ends the stream at tick.

pub fn progress_sink(&self) -> ProgressSink

Where a cursor over a contract passes progress on while the decoder reads a frame through it, and where the decoder says what it still holds: this output, without its event type. Every call returns a handle to the same state.

Trait Implementations

impl<T> Debug for Outbox<T>

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

Formats the value using the given formatter.