Struct canal::broadcast::Consumer

pub struct Consumer<T> { /* 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

Returns a copy of the value.

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

Performs copy-assignment from source.