Struct Consumer 

pub struct Consumer<Backend> { /* private fields */ }

Implementations

impl<Backend> Consumer<Backend>

where Backend: Backend + 'static,

pub fn new(backend: Backend) -> Result<Self>

pub fn add_error_handler(&mut self, handler: impl ErrorHandler + 'static)

pub fn register_handler<S>(&mut self) -> Result<()>

where S: JobHandler + 'static,

pub fn start(&mut self)

pub async fn drain(&mut self, from_backend: bool) -> Result<()>

Trait Implementations

impl<Backend> Debug for Consumer<Backend>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.