use futures::stream::StreamExt;
use mco_redis_rs::{AsyncCommands, AsyncIter};

#[tokio::main]
async fn main() -> mco_redis_rs::RedisResult<()> {
    let client = mco_redis_rs::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(())
}