Struct Outbound 

pub struct Outbound {
    pub data: Sender<DataFrame>,
    pub sys: Sender<(Direction, SystemFrame)>,
}

The send surface of a stage: typed sends for the data and system lanes.

send_data targets the downstream data lane; send_system targets the system lane with an explicit Direction.

Fields

data: Sender<DataFrame>

Downstream data channel.

sys: Sender<(Direction, SystemFrame)>

Bidirectional system channel.

Implementations

impl Outbound

pub async fn send_data(&self, frame: DataFrame) -> Result<(), SendError>

Send a data frame downstream.

Takes &self (not &mut self) so a stage can send while it is borrowed immutably by the run loop. futures’ Sink::send needs &mut, so we send on a cheap clone of the shared sender; clones feed the same channel.

pub async fn send_system( &self, dir: Direction, frame: SystemFrame, ) -> Result<(), SendError>

Send a system frame in the given direction. Takes &self for the same reason as send_data.