Struct RawInput

pub struct RawInput {
    pub rx: MessageReceiver,
    pub source: NodeLayout,
    pub layout: InputLayout,
}

Not typed Input to receive data from the dataflow

Fields

rx: MessageReceiver

The receiver part of the MPSC channel

source: NodeLayout

The source node layout, useful for debugging

layout: InputLayout

The layout of the input, useful for debugging

Implementations

impl RawInput

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

Create a new RawInput instance

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

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

pub async fn recv(&mut self) -> Result<(Header, ArrayData)>

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.