Struct rdkafka_wrap::consumer::base_consumer::PartitionQueue

pub struct PartitionQueue<C>where
    C: ConsumerContext,{ /* private fields */ }

A message queue for a single partition.

Implementations

impl<C> PartitionQueue<C>where C: ConsumerContext,

pub fn poll<T>( &self, timeout: T ) -> Option<Result<BorrowedMessage<'_>, KafkaError>>where T: Into<Timeout>,

Polls the partition for new messages.

The timeout parameter controls how long to block if no messages are available.

Remember that you must also call BaseConsumer::poll on the associated consumer regularly, even if no messages are expected, to serve callbacks.

pub fn set_nonempty_callback<F>(&mut self, f: F)where F: Fn() + Send + Sync + 'static,

Sets a callback that will be invoked whenever the queue becomes nonempty.

Trait Implementations

impl<C> Drop for PartitionQueue<C>where C: ConsumerContext,

fn drop(&mut self)

Executes the destructor for this type.