Struct Input

pub struct Input<T>
where
    T: ArrowMessage,
{
    pub raw: RawInput,
    /* private fields */
}

Typed Input to receive data from the dataflow

Fields

raw: RawInput

Implementations

impl<T> Input<T>

where T: ArrowMessage,

pub fn new( rx: Receiver<DataflowMessage>, source: NodeID, layout: InputID, ) -> Input<T>

Create a new typed Input from a MessageReceiver, NodeID, and InputID

pub async fn recv(&mut self) -> Result<TypedDataflowMessage<T>, Report>

Receive a message from the channel and converting it from Arrow format, asyncronously

Trait Implementations

impl<T> Debug for Input<T>

where T: Debug + ArrowMessage,

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

Formats the value using the given formatter.