Struct canal::broadcast::Consumer
[−]
[src]
pub struct Consumer<T> { /* fields omitted */ }
Struct that receives messages from Broadcast.
Methods
impl<T> Consumer<T>
[src]
fn recv(&self) -> Result<T, BroadcastError<T>>
Receive a message from the Broadcast.
This function will block.
Trait Implementations
impl<T> Clone for Consumer<T>
[src]
fn clone(&self) -> Self
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0
Performs copy-assignment from source
. Read more