Struct CursorPager 

pub struct CursorPager<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 paginated items.

This pager manages cursor state internally and fetches pages on-demand, yielding individual items from the stream.

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> CursorPager<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 cursor 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 = CursorPager::new(query, |q| async move {
    client.list_users(q).await
});

Trait Implementations

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

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

type Item = Result<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 CursorPager<T, E, F, Fut>

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