[][src]Trait lapin::ConsumerDelegate

pub trait ConsumerDelegate: Send + Sync {
    fn on_new_delivery(
        &self,
        delivery: DeliveryResult
    ) -> Pin<Box<dyn Future<Output = ()> + Send>>; fn drop_prefetched_messages(
        &self
    ) -> Pin<Box<dyn Future<Output = ()> + Send>> { ... } }

Required methods

fn on_new_delivery(
    &self,
    delivery: DeliveryResult
) -> Pin<Box<dyn Future<Output = ()> + Send>>

Loading content...

Provided methods

fn drop_prefetched_messages(&self) -> Pin<Box<dyn Future<Output = ()> + Send>>

Loading content...

Implementors

impl<F: Future<Output = ()> + Send + 'static, DeliveryHandler: Fn(DeliveryResult) -> F + Send + Sync + 'static> ConsumerDelegate for DeliveryHandler[src]

Loading content...