| use futures::stream::StreamExt; |
| use redis::{AsyncCommands, AsyncIter}; |
| |
| #[tokio::main] |
| async fn main() -> redis::RedisResult<()> { |
| let client = redis::Client::open("redis://127.0.0.1/").unwrap(); |
| let mut con = client.get_async_connection().await?; |
| |
| con.set("async-key1", b"foo").await?; |
| con.set("async-key2", b"foo").await?; |
| |
| let iter: AsyncIter<String> = con.scan().await?; |
| let mut keys: Vec<_> = iter.collect().await; |
| |
| keys.sort(); |
| |
| assert_eq!( |
| keys, |
| vec!["async-key1".to_string(), "async-key2".to_string()] |
| ); |
| Ok(()) |
| } |