Struct AckOptions

pub struct AckOptions { /* private fields */ }

Set of options that are required by RedisStream::ack_entry()

Implementations

impl AckOptions

pub fn new(stream: String, group: String, entry_id: EntryId) -> Self

Examples found in repository

examples/stream_consumer.rs (line 158)

fn ack_stream_entry(manager: RedisStream, stream: String, group: String, id_to_ack: EntryId)
                    -> impl Future<Item=RedisStream, Error=RedisError> {
    let options = AckOptions::new(stream.clone(), group.clone(), id_to_ack.clone());

    manager.ack_entry(options)
        .map(move |(manager, response)| {
            match response {
                AckResponse::Ok => println!("{:?} is acknowledged", id_to_ack.to_string()),
                AckResponse::NotExists =>
                    eprintln!("Couldn't acknowledge {:?}", id_to_ack.to_string())
            };
            manager
        })
}

Trait Implementations

impl Clone for AckOptions

fn clone(&self) -> AckOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.