Trait net_queue::Consumer

source · [−]
pub trait Consumer: Stream<Item = Result<JobResult<Self::Handle>, Self::Err>> {
    type Err: Debug;
    type Handle: JobHandle<Err = Self::Err>;
}
Expand description

A Consumer for a JobQueue

Required Associated Types

Type of error that can occur while fetching jobs

Type of JobHandle used to acknowledge jobs in this Consumer

Implementors