Struct ReadStreamOptions 

pub struct ReadStreamOptions {
    pub polling_interval: Option<Duration>,
    pub timeout: Option<Duration>,
}

How a stream read waits: how often it looks, and how long it waits for each value.

Constructed with ..Default::default(), as SendOptions is. Where the read starts is an argument rather than an option: read_stream starts at the beginning, read_stream_from at an offset, and read_stream_value reads exactly one.

Fields

polling_interval: Option<Duration>

How often to look again while waiting, if nothing wakes the reader sooner. None is DEFAULT_STREAM_POLLING_INTERVAL; anything under MIN_STREAM_POLLING_INTERVAL is refused.

timeout: Option<Duration>

How long to wait for each value, or None to wait as long as the producer runs.

The clock restarts every time a value is delivered. Expiry is Error::StreamTimeout.

Trait Implementations

impl Clone for ReadStreamOptions

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ReadStreamOptions

impl Debug for ReadStreamOptions

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

Formats the value using the given formatter.

impl Default for ReadStreamOptions

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ReadStreamOptions

impl PartialEq for ReadStreamOptions

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ReadStreamOptions