Struct PagesPager 

pub struct PagesPager<T, E, F, Fut>
where
    F: FnMut(ODataQuery) -> Fut,
    Fut: Future<Output = Result<Page<T>, E>>,
{ /* private fields */ }

A cursor-based pager that implements Stream for pages.

This pager yields entire pages instead of individual items.

Type Parameters

• T - The item type
• E - The error type
• F - The fetcher function type
• Fut - The future returned by the fetcher

Implementations

impl<T, E, F, Fut> PagesPager<T, E, F, Fut>

where F: FnMut(ODataQuery) -> Fut, Fut: Future<Output = Result<Page<T>, E>>,

pub fn new(base_query: ODataQuery, fetcher: F) -> Self

Create a new pages pager with the given base query and fetcher function.

Arguments

• base_query - The base OData query (without cursor)
• fetcher - Function that fetches a page given an ODataQuery

Example

let pager = PagesPager::new(query, |q| async move {
    client.list_users(q).await
});

Trait Implementations

impl<T, E, F, Fut> Stream for PagesPager<T, E, F, Fut>

where F: FnMut(ODataQuery) -> Fut, Fut: Future<Output = Result<Page<T>, E>>,

type Item = Result<Page<T>, PagerError<E>>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, T, E, F, Fut> Unpin for PagesPager<T, E, F, Fut>

where PinnedFieldsOf<__Origin<'__pin, T, E, F, Fut>>: Unpin, F: FnMut(ODataQuery) -> Fut, Fut: Future<Output = Result<Page<T>, E>>,