Struct LongpollConsumer 

pub struct LongpollConsumer { /* private fields */ }

Tokenless long-poll consumer. Construct via LongpollConsumer::new or LongpollConsumer::builder.

Implementations

impl LongpollConsumer

pub fn new(category: impl Into<String>) -> Self

Build a consumer with the standard defaults.

Panics

Panics only if reqwest::Client::build() fails — exceedingly rare.

pub fn builder(category: impl Into<String>) -> LongpollConsumerBuilder

Begin building a LongpollConsumer.

pub fn iterate(&self, opts: LongpollIterateOptions) -> LongpollPoll

Begin a longpoll subscription. Returns a LongpollPoll handle whose typed streams (matches / notifications / errors) are fed by a background tokio task. Drop the handle (or call close().await) to shut it down.

Server keepalive ticks ({"timeout": "no events before timeout"}) are silently absorbed.

pub fn close(self)

Drop the underlying HTTP transport explicitly. Equivalent to dropping the LongpollConsumer.

Trait Implementations

impl Clone for LongpollConsumer

fn clone(&self) -> LongpollConsumer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LongpollConsumer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.