redust 0.4.0

A simple Redis client for Rust.
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

use serde::{Deserialize, Serialize};

use super::{read::Entries, Id};

/// Response from [`XAUTOCLAIM`](https://redis.io/commands/xautoclaim/).
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct AutoclaimResponse<'a>(
	/// The ID to use in the next `XAUTOCLAIM` call.
	pub Id,
	/// The entries which were claimed in this call.
	#[serde(borrow)]
	pub Entries<'a>,
	/// Entries removed from the PEL.
	#[serde(default)]
	pub Vec<Id>,
);

#[cfg(test)]
mod test {
	use redust_resp::from_bytes;

	use crate::model::stream::{
		read::{Entries, Entry, Field, Value},
		Id,
	};

	use super::AutoclaimResponse;

	#[test]
	fn de() {
		let data =
			b"*3\r\n+0-0\r\n*1\r\n*2\r\n+1234-5678\r\n*2\r\n$5\r\nfield\r\n$5\r\nvalue\r\n*0\r\n";

		let (res, rem) = from_bytes::<AutoclaimResponse>(data).unwrap();
		let mut entries = Entries::default();
		let mut entry = Entry::new();

		let field = Field(b"field"[..].into());
		let value = Value(b"value"[..].into());
		entry.insert(field, value);

		entries.0.insert(Id(1234, 5678), entry);

		assert_eq!(res, AutoclaimResponse(Id(0, 0), entries, Vec::new()));
		assert_eq!(rem, []);
	}
}