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: NodeID, layout: InputID) -> Self

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

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