Struct Consumer

pub struct Consumer<'a, F>
where
    F: FnMut(&str, &Message) -> Result<()>,
{
    pub count: Option<usize>,
    pub group: Option<(String, String)>,
    pub handled_messages: u32,
    pub handler: F,
    pub next_pos: String,
    pub process_pending: bool,
    pub redis: &'a mut Connection,
    pub stream: String,
    pub timeout: usize,
}

Fields

count: Option<usize>

group: Option<(String, String)>

handled_messages: u32

handler: F

next_pos: String

process_pending: bool

redis: &'a mut Connection

stream: String

timeout: usize

Implementations

impl<'a, F> Consumer<'a, F>

where F: FnMut(&str, &Message) -> Result<()>,

pub fn init( redis: &'a mut Connection, stream: &str, handler: F, opts: ConsumerOpts, ) -> Result<Self>

Initializes a new stream::Consumer.

pub fn consume(&mut self) -> Result<()>

Handle new messages from the stream, and dispatch them to the registered handler.