Struct canal::broadcast::Consumer

pub struct Consumer<T> {
    // some fields omitted
}

Struct that receives messages from Broadcast.

Methods

impl<T> Consumer<T>

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>

fn clone(&self) -> Self

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