Struct ReadOptions 

pub struct ReadOptions {
    pub count: Option<u64>,
    pub block: Option<Duration>,
}

Options for XREAD and XREADGROUP commands

Fields

count: Option<u64>

Maximum number of entries per stream

block: Option<Duration>

Block timeout in milliseconds (None for non-blocking)

Implementations

impl ReadOptions

pub fn new() -> Self

Create new read options

pub fn with_count(self, count: u64) -> Self

Set the maximum number of entries per stream

pub fn with_block(self, timeout: Duration) -> Self

Set the block timeout

pub fn blocking(timeout: Duration) -> Self

Create blocking read options

pub fn non_blocking(count: u64) -> Self

Create non-blocking read options with count limit

Trait Implementations

impl Clone for ReadOptions

fn clone(&self) -> ReadOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadOptions

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

Formats the value using the given formatter.

impl Default for ReadOptions

fn default() -> Self

Returns the “default value” for a type.