Struct RawOutput

pub struct RawOutput {
    pub tx: Vec<Sender<DataflowMessage>>,
    pub clock: Arc<HLC>,
    pub source: NodeID,
    pub layout: OutputID,
}

Not typed Output to receive data from the dataflow

Fields

tx: Vec<Sender<DataflowMessage>>

The senders parts of MPSC channels

clock: Arc<HLC>

The shared clock of the runtime

source: NodeID

The source node layout, useful for debugging

layout: OutputID

The layout of the output, useful for debugging

Implementations

impl RawOutput

pub fn new( tx: Vec<Sender<DataflowMessage>>, clock: Arc<HLC>, source: NodeID, layout: OutputID, ) -> RawOutput

Create a new RawOutput instance

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

Send a message asynchronously to all connected nodes.