Struct Sender

pub struct Sender<T> { /* private fields */ }

a Sender is used to push Samples to the Receiver it is clonable for sharing between threads

Implementations

impl<T: Hash + Eq + Send + Clone> Sender<T>

pub fn new( rx_queue: Arc<Queue<Vec<Sample<T>>>>, data_tx: SyncSender<Vec<Sample<T>>>, control_tx: SyncSender<ControlMessage<T>>, batch_size: usize, ) -> Sender<T>

create a new Sender for use in client threads

pub fn send(&mut self, sample: Sample<T>) -> Result<(), Error>

a function to send a Sample to the Receiver

pub fn add_interest(&mut self, interest: Interest<T>)

register an Interest

pub fn remove_interest(&mut self, interest: Interest<T>)

de-register an Interest

pub fn set_batch_size(&mut self, batch_size: usize)

a function to change the batch size of the Sender

pub fn try_send(&mut self, sample: Sample<T>) -> Result<(), Sample<T>>

mock try_send Sample to the Receiver

Trait Implementations

impl<T: Clone> Clone for Sender<T>

fn clone(&self) -> Sender<T>

Returns a copy of the value.

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

Performs copy-assignment from source.