[][src]Trait lapin_futures::ConsumerSubscriber

pub trait ConsumerSubscriber: Send + Sync + Debug {
    fn new_delivery(&self, delivery: Delivery);
fn drop_prefetched_messages(&self);
fn cancel(&self); }

Required methods

fn new_delivery(&self, delivery: Delivery)

fn drop_prefetched_messages(&self)

fn cancel(&self)

Loading content...

Implementors

impl ConsumerSubscriber for Consumer[src]

Loading content...