Struct SubscribeOpts 

pub struct SubscribeOpts { /* private fields */ }

Options for subscribing to events.

Implementations

impl SubscribeOpts

pub fn limit(self, limit: usize) -> Self

Set the maximum number of events per poll.

pub fn filter(self, filter: Filter) -> Self

Set an event filter.

pub fn ordering(self, ordering: Ordering) -> Self

Set the event ordering.

pub fn poll_interval(self, interval: Duration) -> Self

Set the base poll interval.

Pre-fix, Duration::ZERO was accepted verbatim, and combined with a zero max_backoff the doubling loop at current_interval = (current_interval * 2).min(max_backoff) resolved to zero forever. The poll-then-zero-sleep-then- wake_by_ref path then ran at 100 % CPU on an idle stream. Clamp to a minimum of 1 ns so even pathological inputs stay out of the spin path; production callers wanting a tight poll should set Duration::from_millis(1) or similar.

pub fn max_backoff(self, max: Duration) -> Self

Set the maximum backoff interval.

See poll_interval — the same zero-collapse hazard applies. Clamped to a minimum of 1 ns so the doubling loop always parks the task on a real timer rather than spinning.

Trait Implementations

impl Clone for SubscribeOpts

fn clone(&self) -> SubscribeOpts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscribeOpts

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

Formats the value using the given formatter.

impl Default for SubscribeOpts

fn default() -> Self

Returns the “default value” for a type.