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>)

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

Each sender is awaited independently — a slow downstream does not block enqueue to sibling downstreams. The function returns after all senders have completed their publish (enqueue or completion, depending on blocking_callbacks).

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

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.