Struct FetchIter

pub struct FetchIter<'a> { /* private fields */ }

Iterator to fetch messages from within queue.

If fetch parameters are to query new messages, it will only return freshly added messages. Once these messages are fetched, they are considered pending and no longer returned by this iterator

If fetch parameter specifies to return pending messages within queue, then iterator will resume after last message id.

Implementations

impl<'a> FetchIter<'a>

pub fn new(params: FetchParams<'a>, queue: Queue) -> Self

Creates new iterator

pub fn set_count(&mut self, count: usize)

Sets number of items to fetch

pub fn set_cursor(&mut self, typ: FetchType)

Sets cursor to position where to iterate from.

pub fn set_timeout(&mut self, timeout: Duration)

Sets time waiting to fetch data.

Redis will return reply within this time, not necessary immediately even if data is available.

pub async fn next<T: FromRedisValue>( &mut self, ) -> Result<FetchResult<T>, RedisError>

Performs fetch, returning messages depending on FetchParams::typ.

If pending messages are fetched, moves cursor to last pending message after fetched messages.

We fetch our task as raw bytes to ensure we can always get it, regardless how it was serialized.

pub async fn next_entries<T: FromRedisValue>( &mut self, ) -> Result<Vec<Entry<T>>, RedisError>

Performs fetch, returning messages depending on FetchParams::typ.

If pending messages are fetched, moves cursor to last pending message after fetched messages.

We fetch our task as raw bytes to ensure we can always get it, regardless how it was serialized.

Differently from next it returns only list of entries