tk-redis 0.1.3

A minimal redis client library based on futures+tokio-core
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

extern crate tk_redis;
extern crate tokio_core;
extern crate futures;

use futures::future::Future;
use futures::sync::oneshot;
use std::str::FromStr;
use std::thread;

#[test]
fn connect_to_redis() {
    let info = tk_redis::ConnectionInfo {
        addr: FromStr::from_str("127.0.0.1:6379").unwrap(),
        password: None,
        db: 0,
        max_connections: 8,
    };

    let (tx, rx) = oneshot::channel();
    thread::spawn(move || {
        let mut core = tokio_core::reactor::Core::new().unwrap();
        tx.complete(core.remote());
        loop {
            core.turn(None);
        }
    });
    let util_remote = rx.wait().unwrap();

    let pool = tk_redis::Pool::new(info);
    let task = pool.pop(util_remote.clone())
        .and_then(|redis| {
            // Delete any existing key
            redis.exec("DEL", "test/key")
        })
        .and_then(|(redis, result)| {
            assert!(result.is_int());
            // Set our key to a value
            redis.exec("SET", ("test/key", "test-value"))
        })
        .and_then(|(redis, result)| {
            assert!(result.is_okay());
            // Get the value back out
            redis.exec("GET", "test/key")
        })
        .map(|(_, result)| {
            // Make sure we got it
            assert_eq!(result.as_str(), Some("test-value"))
        })
        .map_err(|_| ());

    let mut core = tokio_core::reactor::Core::new().unwrap();
    core.run(task).expect("Failed to connect and send commands");
}