Struct RawOutput

pub struct RawOutput {
    pub tx: Vec<MessageSender>,
    pub clock: Arc<HLC>,
    pub source: NodeLayout,
    pub layout: OutputLayout,
}

Not typed Output to receive data from the dataflow

Fields

tx: Vec<MessageSender>

The senders parts of MPSC channels

clock: Arc<HLC>

The shared clock of the runtime

source: NodeLayout

The source node layout, useful for debugging

layout: OutputLayout

The layout of the output, useful for debugging

Implementations

impl RawOutput

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

Create a new RawOutput instance

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

Send a message from the channel, blocking until it’s possible, don’t use it in async context

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

Send a message asynchronously to all connected nodes.