A RetroSearch Logo

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Search Query:

Showing content from https://docs.rs/rdkafka/*/rdkafka/consumer/base_consumer/struct.PartitionQueue.html below:

PartitionQueue in rdkafka::consumer::base_consumer - Rust

rdkafka

::

consumer

::

base_consumer Struct PartitionQueueSource 
pub struct PartitionQueue<C>
where C: 
ConsumerContext
,
{ /* private fields */ }
Expand description

A message queue for a single partition.

Implementations§ Source§ impl<C> PartitionQueue<C>

where C:

ConsumerContext

,

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

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 events.

Source 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§ Source§ impl<C> Drop for PartitionQueue<C>

where C:

ConsumerContext

,

Source§ fn drop(&mut self)

Executes the destructor for this type.

Read more Auto Trait Implementations§ § impl<C> Freeze for PartitionQueue<C> § impl<C> !RefUnwindSafe for PartitionQueue<C> § impl<C> Send for PartitionQueue<C> § impl<C> Sync for PartitionQueue<C> § impl<C> Unpin for PartitionQueue<C> § impl<C> !UnwindSafe for PartitionQueue<C> Blanket Implementations§ Source§ impl<T> Any for T

where T: 'static + ?

Sized

,

Source§ fn type_id(&self) -> TypeId

Gets the

TypeId

of

self

.

Read more Source§ impl<T> Borrow<T> for T

where T: ?

Sized

,

Source§ fn borrow(&self) -> &T

Immutably borrows from an owned value.

Read more Source§ impl<T> BorrowMut<T> for T

where T: ?

Sized

,

Source§ fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value.

Read more Source§ impl<T> From<T> for T Source§ fn from(t: T) -> T

Returns the argument unchanged.

Source§ impl<T> Instrument for T Source§ fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided

Span

, returning an

Instrumented

wrapper.

Read more Source§ fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the

current Span

, returning an

Instrumented

wrapper.

Read more Source§ impl<T, U> Into<U> for T

where U:

From

<T>,

Source§ fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§ impl<T, U> TryFrom<U> for T

where U:

Into

<T>,

Source§ type Error = Infallible

The type returned in the event of a conversion error.

Source§ fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

Source§ impl<T, U> TryInto<U> for T

where U:

TryFrom

<T>,

Source§ type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

Source§ fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

Source§ impl<T> WithSubscriber for T Source§ fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>

where S:

Into

<

Dispatch

>,

Attaches the provided

Subscriber

to this type, returning a

WithDispatch

wrapper.

Read more Source§ fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current

default Subscriber

to this type, returning a

WithDispatch

wrapper.

Read more

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4