Skip to main content

StateIterator

tycho_collator::internal_queue::state::state_iterator

Trait StateIterator 

Source 
pub trait StateIterator<V: InternalMessageValue>: Send {
    // Required methods
    fn next(&mut self) -> Result<Option<MessageExt<V>>>;
    fn current_position(&self) -> FastHashMap<ShardIdent, QueueKey>;
}

Required Methods§

Source

fn next(&mut self) -> Result<Option<MessageExt<V>>>

Source

fn current_position(&self) -> FastHashMap<ShardIdent, QueueKey>

Implementors§