Trait lapin::ConsumerDelegate
source · pub trait ConsumerDelegate: Send + Sync {
// Required method
fn on_new_delivery(
&self,
delivery: DeliveryResult
) -> Pin<Box<dyn Future<Output = ()> + Send>>;
// Provided method
fn drop_prefetched_messages(
&self
) -> Pin<Box<dyn Future<Output = ()> + Send>> { ... }
}