Struct tic::Sender

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

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

Methods

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.