Struct NDArrayOutput 

pub struct NDArrayOutput { /* private fields */ }

Fan-out: publishes arrays to multiple downstream receivers.

Implementations

impl NDArrayOutput

pub fn new() -> Self

pub fn add(&mut self, sender: NDArraySender)

pub fn remove(&mut self, port_name: &str)

pub fn take(&mut self, port_name: &str) -> Option<NDArraySender>

Remove a sender by port name and return it (if found).

pub async fn publish(&self, array: Arc<NDArray>) -> Vec<PublishOutcome>

Publish an array to all downstream receivers (async, concurrent).

Each sender publishes independently. Returns the per-sender outcomes so the caller can count DroppedArrays for any downstream whose queue was full (C++ driverCallback semantics).

pub async fn publish_to( &self, index: usize, array: Arc<NDArray>, ) -> Option<PublishOutcome>

Publish an array to a single downstream receiver by index (for scatter/round-robin).

pub fn num_senders(&self) -> usize

Trait Implementations

impl Default for NDArrayOutput

fn default() -> Self

Returns the “default value” for a type.