Struct Output

pub struct Output<T: ArrowMessage> {
    pub raw: RawOutput,
    /* private fields */
}

Typed Output to receive data from the dataflow

Fields

raw: RawOutput

Implementations

impl<T: ArrowMessage> Output<T>

pub fn new( tx: Vec<MessageSender>, clock: Arc<HLC>, source: NodeLayout, layout: OutputLayout, ) -> Self

Create a new typed Output from a MessageSender, NodeLayout, and OutputLayout

pub fn blocking_send(&self, data: T) -> Result<()>

Send a message to the output, blocking the current thread until the message is sent. Don’t use in async context

pub async fn send(&self, data: T) -> Result<()>

Send a message to the output asynchronously.