Function find_all_stream

examples/basic/src/select.rs:292–338

(db: &DbConn)

}

async fn find_all_stream(db: &DbConn) -> Result<(), DbErr> {
    use async_std::task::sleep;
    use futures::TryStreamExt;
    use std::time::Duration;

    println!("find all cakes paginated: ");
    let mut cake_paginator = cake::Entity::find().paginate(db, 3);
    while let Some(cake_res) = cake_paginator.fetch_and_next().await? {
        for cake in cake_res {
            println!("{cake:?}");
        }
    }

    println!();
    println!("find all fruits paginated: ");
    let mut fruit_paginator = fruit::Entity::find().paginate(db, 3);
    while let Some(fruit_res) = fruit_paginator.fetch_and_next().await? {
        for fruit in fruit_res {
            println!("{fruit:?}");
        }
    }

    println!();
    println!("find all fruits with stream: ");
    let mut fruit_stream = fruit::Entity::find().paginate(db, 3).into_stream();
    while let Some(fruits) = fruit_stream.try_next().await? {
        for fruit in fruits {
            println!("{fruit:?}");
        }
        sleep(Duration::from_millis(250)).await;
    }

    println!();
    println!("find all fruits in json with stream: ");
    let mut json_stream = fruit::Entity::find()
        .into_json()
        .paginate(db, 3)
        .into_stream();
    while let Some(jsons) = json_stream.try_next().await? {
        for json in jsons {
            println!("{json:?}");
        }
        sleep(Duration::from_millis(250)).await;
    }

    Ok(())
}

async fn find_first_page(db: &DbConn) -> Result<(), DbErr> {
    println!("fruits first page: ");