Struct StreamOptionsBuilder

pub struct StreamOptionsBuilder { /* private fields */ }

Builder for StreamOptions.

Implementations

impl StreamOptionsBuilder

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

Set the polling interval.

pub fn buffer_size(self, size: usize) -> Self

Set the buffer size.

pub fn include_errors(self, include: bool) -> Self

Set whether to include errors in the stream.

When true, read errors are sent as Err(Error) items to the stream, allowing consumers to detect disconnections and other issues.

pub fn max_consecutive_failures(self, max: u32) -> Self

Set the maximum consecutive failures before auto-closing.

When set, the stream will automatically close after this many consecutive read failures, indicating a likely disconnection.

pub fn build(self) -> StreamOptions

Build the StreamOptions.

Trait Implementations

impl Clone for StreamOptionsBuilder

fn clone(&self) -> StreamOptionsBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamOptionsBuilder

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

Formats the value using the given formatter.

impl Default for StreamOptionsBuilder

fn default() -> StreamOptionsBuilder

Returns the “default value” for a type.