Struct NDArrayOutput 

pub struct NDArrayOutput { /* private fields */ }

Fan-out: broadcasts 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 fn publish(&self, array: Arc<NDArray>)

Publish an array to all downstream receivers.

pub fn total_dropped(&self) -> u64

pub fn num_senders(&self) -> usize

Trait Implementations

impl Default for NDArrayOutput

fn default() -> Self

Returns the “default value” for a type.