Crate redis_ac

redis-ac is a helper crate for redis, which provides asynchronous version of redis::Commands.

Commands trait of this crate is automatically implemented for any types which implement redis::aio::ConnectionLike.

Non-scan command methods of Commands return a future.

use futures::prelude::*;
use redis_ac::Commands;

let client = redis::Client::open("redis://127.0.0.1").unwrap();
let connect = client.get_async_connection();

let f = connect.and_then(|con|{
    con.set("key", "value")
        .and_then(|(con, res): (_, String)| {
            assert_eq!(res, "OK");
            con.get("key")
        })
        .and_then(|(_, res): (_, String)| {
            assert_eq!(res, "value");
            Ok(())
        })
}).map_err(|e| eprintln!("{}", e));

tokio::run(f);

Scan command methods of Commands return a stream over scanned items.

The stream returns tuples of an optional connection object and an optional item. When the last item is returned, the optional value becomes Some which holds the connection object passed to the method. Until then, it is None. The item is normally Some. It is set to None only if no items are found by scan. In such case, the stream just returns (Some, None) and finishes.

use futures::prelude::*;
use redis_ac::Commands;

let client = redis::Client::open("redis://127.0.0.1").unwrap();
let connect = client.get_async_connection();

let f = connect.and_then(|con|{
    con.scan_match("key*")
        .for_each(|(con, item): (_, Option<String>)| {
            println!("{:?}", item);
            if con.is_some() {
                // The last item comes with the connection object.
                if item.is_none() {
                    // If no items found by scan, `(Some(con), None)` is given.
                    println!("No item");
                }
            }
            Ok(())
        })
}).map_err(|e| eprintln!("{}", e));

tokio::run(f);

If you are interested in only items, filter_map can be used to simplify.

use futures::prelude::*;
use redis_ac::Commands;

let client = redis::Client::open("redis://127.0.0.1").unwrap();
let connect = client.get_async_connection();

let f = connect.and_then(|con|{
    con.scan_match("key*")
        .filter_map(|(_, item)| item)
        .for_each(|item: String| {
            // Here we get only items.
            Ok(())
        })
}).map_err(|e| eprintln!("{}", e));

tokio::run(f);

Structs

RedisScanAll	Collects all the results from a scan command.
RedisScanStream	Stream over items of scan commands.

Traits

Commands

Asynchronous version of redis::Commands.