Struct InternalQueueMessagesIter 

pub struct InternalQueueMessagesIter {
    pub inner: OwnedRawIterator,
    pub first: bool,
}

Iterator for internal queue messages.

Fields

inner: OwnedRawIterator

first: bool

Implementations

impl InternalQueueMessagesIter

pub fn seek(&mut self, key: &ShardsInternalMessagesKey)

Moves the iterator to the specified key.

Arguments

• key - The key to seek to.

pub fn seek_to_first(&mut self)

Moves the iterator to the first element.

pub fn next(&mut self) -> Result<Option<InternalQueueMessage<'_>>>

Retrieves the next message from the iterator.

Returns

• Ok(Some(InternalQueueMessage<'_>)) if there is a next message.
• Ok(None) if the iterator has reached the end.
• Err(anyhow::Error) if an error occurs.