[−][src]Trait lapin_futures::ConsumerDelegate

pub trait ConsumerDelegate: Send + Sync {
    fn on_new_delivery(&self, delivery: Result<Option<Delivery>, Error>);

    fn drop_prefetched_messages(&self) { ... }
}

Required methods

fn on_new_delivery(&self, delivery: Result<Option<Delivery>, Error>)

Loading content...

Provided methods

fn drop_prefetched_messages(&self)

Loading content...

Implementors

impl<DeliveryHandler> ConsumerDelegate for DeliveryHandler where
    DeliveryHandler: Send + Sync + Fn(Result<Option<Delivery>, Error>), [src]

Loading content...