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

use async_trait::async_trait;
use futures::{future::ready, TryStreamExt};
use redust_resp::{from_data, Data};
use tracing::instrument;

use crate::{model::pubsub::Response, Connection, Result};

use super::Command;

/// Unsubscribe from all channels and return this connection to normal mode.
#[derive(Debug)]
pub struct Unsubscribe;

#[async_trait]
impl Command for Unsubscribe {
	type Response = Vec<Data<'static>>;

	#[instrument(ret, level = "debug")]
	async fn run(self, connection: &mut Connection) -> Result<Self::Response> {
		connection
			.pipeline([["unsubscribe"], ["punsubscribe"]])
			.await?;

		connection
			.try_take_while(|data| {
				ready(from_data::<Response>(data.clone()).map(
					|response| matches!(response, Response::Unsubscribe(sub) if sub.is_in_pubsub_mode()),
				))
			})
			.try_collect()
			.await
	}
}