Struct ncryptf::deadpool_redis::redis::AsyncIter

pub struct AsyncIter<'a, T>
where
    T: FromRedisValue + 'a,
{ /* private fields */ }

Represents a redis iterator that can be used with async connections.

Implementations

impl<'a, T> AsyncIter<'a, T>

where T: FromRedisValue + 'a + Unpin + Send,

pub async fn next_item(&mut self) -> Option<T>

con.sadd("my_set", 42i32).await?;
con.sadd("my_set", 43i32).await?;
let mut iter: redis::AsyncIter<i32> = con.sscan("my_set").await?;
while let Some(element) = iter.next_item().await {
    assert!(element == 42 || element == 43);
}

Trait Implementations

impl<'a, T> Stream for AsyncIter<'a, T>

where T: FromRedisValue + Unpin + Send + 'a,

type Item = T

Values yielded by the stream.

fn poll_next( self: Pin<&mut AsyncIter<'a, T>>, cx: &mut Context<'_> ) -> Poll<Option<T>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.