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: NodeLayout, layout: InputLayout, ) -> Input<T>

Create a new typed Input from a MessageReceiver, NodeLayout, and InputLayout

pub fn blocking_recv(&mut self) -> Result<(Header, T), Report>

Receive a message from the channel and converting it from Arrow format, blocking until one is available, don’t use it in async context

pub async fn recv(&mut self) -> Result<(Header, 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.