Struct NDArraySender 

pub struct NDArraySender { /* private fields */ }

Sender held by upstream. Supports blocking and non-blocking modes.

Implementations

impl NDArraySender

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

Send an array downstream. Behavior depends on mode:

• Disabled (enable_callbacks=0): silently dropped
• Blocking (blocking_callbacks=1): processed inline on caller’s thread
• Non-blocking (default): queued for data thread (dropped if full)

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 dropped_count(&self) -> u64

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.