Struct app_frame::queue_consumer::Dispatch

pub struct Dispatch<P, In>where
    P: BatchProcessor<In>,
    In: Hash + Eq + Clone,{ /* private fields */ }

Implementations

impl<P: BatchProcessor<In>, In: Hash + Eq + Clone> Dispatch<P, In>

pub fn new( provider: QueueReceiver<In>, processor: P, timeout: u64, backoff: Option<BackoffTracker<In>> ) -> Self

pub fn is_empty(&self) -> bool

Trait Implementations

impl<P, In> MutJob for Dispatch<P, In>where P: BatchProcessor<In> + Send + Sync, In: Hash + Eq + Clone + Send + Sync + Debug, P::Intermediate: Send + Sync,

fn run_once_mut<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,