Struct NDArrayDriverBase 

pub struct NDArrayDriverBase {
    pub port_base: PortDriverBase,
    pub params: NDArrayDriverParams,
    pub pool: Arc<NDArrayPool>,
    pub array_output: NDArrayOutput,
    pub queued_counter: Arc<QueuedArrayCounter>,
}

Base state for asynNDArrayDriver (file handling, attribute mgmt, pool).

Fields

port_base: PortDriverBase

params: NDArrayDriverParams

pool: Arc<NDArrayPool>

array_output: NDArrayOutput

queued_counter: Arc<QueuedArrayCounter>

Implementations

impl NDArrayDriverBase

pub fn new(port_name: &str, max_memory: usize) -> AsynResult<Self>

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

Connect a downstream channel-based receiver.

pub fn num_plugins(&self) -> usize

Number of connected downstream channels.

pub fn publish_array(&mut self, array: Arc<NDArray>) -> AsynResult<()>

Publish an array: update counters, push to plugins and channel outputs.

pub fn create_file_name(&mut self) -> AsynResult<String>

Construct a file path from template, path, name, and number.

pub fn check_path(&mut self) -> AsynResult<bool>

Check if the file path directory exists.