Struct Input

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

Typed Input to receive data from the dataflow

Fields

raw: RawInput

Implementations

impl<T: ArrowMessage> Input<T>

pub fn new(rx: MessageReceiver, source: NodeLayout, layout: InputLayout) -> Self

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

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

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)>

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

Trait Implementations

impl<T: Debug + ArrowMessage> Debug for Input<T>

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

Formats the value using the given formatter.