fred 0.2.5

A Redis client for Rust built on Futures and Tokio.
Documentation 
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107

use futures::future;
use futures::{IntoFuture, Future, Stream};
use futures::stream;

use std::borrow::Borrow;

use fred::error::{
  RedisErrorKind,
  RedisError
};
use fred::types::*;
use fred::RedisClient;

use super::utils;

pub fn should_sadd_members_to_set(client: RedisClient) -> Box<Future<Item=(), Error=RedisError>> {
  // Test adding values to the set "foo" as a vec  
  Box::new(client.sadd("foo", vec![1, 2, 3]).and_then(|(client, len)| {
    assert_eq!(len, 3);
    // Test adding value to the set "foo" as a single int that already exists 
    client.sadd("foo", 1)
  })
  .and_then(|(client, len)| {
    assert_eq!(len, 0);

    // Test adding value to the set "foo" as a single int that doesn't exist
    client.sadd("foo", 4)
  })
  .and_then(|(client, len)| { 
    assert_eq!(len, 1);

    // Test adding value to the set "foo" as a vec that doesn't exist
    client.sadd("foo", vec![5])
  })
  .and_then(|(client, len)| { 
    assert_eq!(len, 1);

    // Test adding values to the set "foo" as a vec that containts two pre-existing values and two new values
    client.sadd("foo", vec![1, 2, 6, 7])
  })
 .and_then(|(client, len)| {
    assert_eq!(len, 2);

    Ok(())
  }))
}

pub fn should_srem_members_of_set(client: RedisClient) -> Box<Future<Item=(), Error=RedisError>> {
  // Test adding values to the set "foo" as a vec for removal 
  Box::new(client.sadd("foo", vec![1, 2, 3]).and_then(|(client, len)| {
    assert_eq!(len, 3);
    // Test removing value from the set "foo" as a single int 
    client.srem("foo", 1)
  })
  .and_then(|(client, len)| {
    assert_eq!(len, 1);

    client.sadd("foo", vec![1, 4])
  })
  .and_then(|(client, len)| { 
    assert_eq!(len, 2);

    // Test removing value from the set "foo" as a vec with two existing values and one non-existing value
    client.srem("foo", vec![1, 2, 5])
  })
  .and_then(|(client, len)| { 
    assert_eq!(len, 2);

    // Test removing value from the set "foo" that does not exist
    client.srem("foo", vec![7])
  })
 .and_then(|(client, len)| {
    assert_eq!(len, 0);

    Ok(())
  }))
}

pub fn should_smembers_of_set(client: RedisClient) -> Box<Future<Item=(), Error=RedisError>> {
  // Test adding values to the set "foo" as a vec for retrieval 
  Box::new(client.sadd("foo", vec![1, 2, 3]).and_then(|(client, len)| {
    assert_eq!(len, 3);
    // Test getting all members from set 
    client.smembers("foo")
  })
  .and_then(|(client, result)| {
    assert_eq!(result.len(), 3);
    
    assert!(result.contains(&RedisValue::String("1".borrow().to_string())));
    assert!(result.contains(&RedisValue::String("2".borrow().to_string())));
    assert!(result.contains(&RedisValue::String("3".borrow().to_string())));

    client.sadd("foo", vec![4])
  })
  .and_then(|(client, len)| { 
    assert_eq!(len, 1);

    // Test getting all members to ensure new addition successfully returned 
    client.smembers("foo")
  })
  .and_then(|(client, result)| { 
    assert_eq!(result.len(), 4);
    assert!(result.contains(&RedisValue::String("4".borrow().to_string())));

    Ok(())
  }))
}