Struct CoalescingIterator

pub struct CoalescingIterator<I> { /* private fields */ }

Implementations

impl<I: LayerIterator<AllocatorKey, AllocatorValue>> CoalescingIterator<I>

pub async fn new(iter: I) -> Result<CoalescingIterator<I>, Error>

Trait Implementations

impl<I: LayerIterator<AllocatorKey, AllocatorValue>> LayerIterator<AllocatorKeyV32, AllocatorValueV32> for CoalescingIterator<I>

fn advance<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Advances the iterator.

fn get(&self) -> Option<ItemRef<'_, AllocatorKey, AllocatorValue>>

Returns the current item. This will be None if called when the iterator is first crated i.e. before either seek or advance has been called, and None if the iterator has reached the end of the layer.

fn filter<'async_trait, P>( self, predicate: P, ) -> Pin<Box<dyn Future<Output = Result<FilterLayerIterator<Self, P, K, V>, Error>> + Send + 'async_trait>>

where P: for<'b> Fn(ItemRef<'b, K, V>) -> bool + Send + Sync + 'async_trait, Self: Sized + 'async_trait, K: Send + Sync, V: Send + Sync,

Creates an iterator that only yields items from the underlying iterator for which predicate returns true.