Struct blinkcast::alloc::Sender

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

The sender of the channel.

This is a cloneable sender, so you can have multiple senders that will send to the same channel.

Broadcast messages sent by using the send method.

Examples

use blinkcast::alloc::channel;

let (sender, mut receiver) = channel::<i32>(4);

sender.send(1);
let sender2 = sender.clone();
sender2.send(2);

assert_eq!(receiver.recv(), Some(1));
assert_eq!(receiver.recv(), Some(2));
assert_eq!(receiver.recv(), None);

Or using the new method:

use blinkcast::alloc::Sender;

let sender = Sender::<i32>::new(4);

let mut receiver = sender.new_receiver();

sender.send(1);
sender.send(2);
assert_eq!(receiver.recv(), Some(1));
assert_eq!(receiver.recv(), Some(2));
assert_eq!(receiver.recv(), None);

Implementations

impl<T: Clone> Sender<T>

pub fn send(&self, value: T)

Sends a message to the channel. If the channel is full, the oldest message will be overwritten. So the receiver must be quick or it will lose the old data.

pub fn new(size: usize) -> Self

Creates a new channel with a buffer of size N.

pub fn new_receiver(&self) -> Receiver<T>

Creates a new receiver that starts from the same point as the sender.

Examples

use blinkcast::alloc::Sender;

let sender = Sender::<i32>::new(4);

sender.send(1);

let mut receiver = sender.new_receiver();
assert_eq!(receiver.recv(), None);

sender.send(2);
assert_eq!(receiver.recv(), Some(2));
assert_eq!(receiver.recv(), None);

Trait Implementations

impl<T> Clone for Sender<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

impl<T: Clone + Send> Sync for Sender<T>