Struct AsyncRangeIter 

pub struct AsyncRangeIter<'a, S: AsyncStore> { /* private fields */ }

Async iterator over key-value pairs in a range.

Created by AsyncProlly::range. Call AsyncRangeIter::next to lazily read one item at a time, or AsyncRangeIter::into_stream to adapt it to a futures_util::Stream.

Implementations

impl<'a, S> AsyncRangeIter<'a, S>

where S: AsyncStore, S::Error: Send + Sync,

pub async fn next(&mut self) -> Option<Result<(Vec<u8>, Vec<u8>), Error>>

Return the next key-value pair in lexicographic order.

pub async fn next_with<R>( &mut self, read: impl for<'entry> FnOnce(EntryRef<'entry>) -> R, ) -> Option<Result<R, Error>>

Visit the next entry without copying its key or value.

The callback is synchronous and runs after any required child load has completed, so its borrowed entry cannot cross an .await boundary.

pub async fn collect(self) -> Result<Vec<(Vec<u8>, Vec<u8>)>, Error>

Collect all remaining range entries into memory.

pub fn resume_cursor(&self) -> RangeCursor

Return a resumable cursor for the last key yielded by this iterator.

If the iterator has not yielded an item yet, this returns RangeCursor::start.

pub fn into_stream( self, ) -> impl Stream<Item = Result<(Vec<u8>, Vec<u8>), Error>> + 'a

Convert this iterator into a futures_util::Stream.