Struct RawInput

pub struct RawInput {
    pub rx: MessageReceiver,
    pub source: NodeID,
    pub layout: InputID,
}

Not typed Input to receive data from the dataflow

Fields

rx: MessageReceiver

The receiver part of the MPSC channel

source: NodeID

The source node layout, useful for debugging

layout: InputID

The layout of the input, useful for debugging

Implementations

impl RawInput

pub fn new(rx: MessageReceiver, source: NodeID, layout: InputID) -> Self

Create a new RawInput instance

pub async fn recv(&mut self) -> Result<DataflowMessage>

Receive a message from the channel, asynchronously

Trait Implementations

impl Debug for RawInput

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

Formats the value using the given formatter.