page-turner 1.0.0

A generic abstraction of APIs with pagination
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

use crate::local::{prelude::*, PageError, PageItems};
use crate::test_utils::*;
use futures::TryStreamExt;

#[tokio::test(flavor = "current_thread")]
async fn pages() {
    pages_base_test!().await;
    generic_pages_usage(NumbersClient::new(17, 3), GetNumbersQuery::default()).await;
}

#[tokio::test(flavor = "current_thread")]
async fn pages_ahead() {
    pages_ahead_base_test!().await;
    generic_pages_ahead_usage(BlogClient::new(49), GetContentRequest { page: 0 }).await;
}

#[tokio::test(flavor = "current_thread")]
async fn pages_ahead_unordered() {
    pages_ahead_unordered_base_test!().await;
    generic_pages_ahead_unordered_usage(BlogClient::new(49), GetContentRequest { page: 0 }).await;
}

page_turner_impls!();

async fn generic_pages_usage<P, R>(p: P, req: R)
where
    P: PageTurner<R>,
    PageItems<P, R>: IntoIterator,
    PageError<P, R>: std::fmt::Debug,
{
    let pages_stream = p.pages(req);
    generic_pages_stream_usage(pages_stream).await;
}

async fn generic_pages_ahead_usage<P, R>(p: P, req: R)
where
    P: PageTurner<R>,
    R: RequestAhead,
    PageItems<P, R>: IntoIterator,
    PageError<P, R>: std::fmt::Debug,
{
    let pages_stream = p.pages_ahead(2, Limit::None, req);
    generic_pages_stream_usage(pages_stream).await;
}

async fn generic_pages_ahead_unordered_usage<P, R>(p: P, req: R)
where
    P: PageTurner<R>,
    R: RequestAhead,
    PageItems<P, R>: IntoIterator,
    PageError<P, R>: std::fmt::Debug,
{
    let pages_stream = p.pages_ahead(2, Limit::None, req);
    generic_pages_stream_usage(pages_stream).await;
}

async fn generic_pages_stream_usage<'p, T, E>(s: impl 'p + PagesStream<'p, T, E>)
where
    T: IntoIterator,
    E: std::fmt::Debug,
{
    std::pin::pin!(s.items()).try_next().await.unwrap();
}

#[cfg(feature = "mutable")]
mod mutable {
    use crate::mutable::{prelude::*, PageError, PageItems};
    use crate::test_utils::*;
    use futures::TryStreamExt;

    #[tokio::test(flavor = "current_thread")]
    async fn pages() {
        pages_base_test!(mut).await;
        generic_pages_usage(NumbersClient::new(19, 5), GetNumbersQuery::default()).await;
    }

    page_turner_impls!(mut);

    async fn generic_pages_usage<P, R>(mut p: P, req: R)
    where
        P: PageTurner<R>,
        PageItems<P, R>: IntoIterator,
        PageError<P, R>: std::fmt::Debug,
    {
        let pages_stream = p.pages(req);
        generic_pages_stream_usage(pages_stream).await;
    }

    async fn generic_pages_stream_usage<'p, T, E>(s: impl 'p + PagesStream<'p, T, E>)
    where
        T: IntoIterator,
        E: std::fmt::Debug,
    {
        std::pin::pin!(s.items()).try_next().await.unwrap();
    }
}