Struct NDArraySender 

pub struct NDArraySender { /* private fields */ }

Sender held by upstream. Fully async, reliable (no drops).

blocking_callbacks semantics

Both modes use reliable async enqueue (send().await). The difference is how long the caller waits:

• blocking_callbacks=0: waits until the message is in the downstream queue (enqueue guaranteed, processing NOT awaited).
• blocking_callbacks=1: waits until the downstream plugin has finished processing the array (enqueue + completion awaited).

Neither mode drops arrays due to back-pressure — the caller yields instead.

Implementations

impl NDArraySender

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

Publish an array downstream (async, reliable).

• enable_callbacks=0: returns immediately, array not sent.
• blocking_callbacks=0: awaits queue admission only.
• blocking_callbacks=1: awaits queue admission + downstream processing completion.

pub fn is_enabled(&self) -> bool

Whether this sender’s plugin has callbacks enabled.

pub fn is_blocking(&self) -> bool

Whether this sender’s plugin is in blocking mode.

pub fn port_name(&self) -> &str

pub fn set_queued_counter(&mut self, counter: Arc<QueuedArrayCounter>)

Set the queued-array counter for tracking in-flight arrays.

Trait Implementations

impl Clone for NDArraySender

fn clone(&self) -> NDArraySender

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.