fs2db 7.3.0

migration helper
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

use futures::StreamExt;

use tonic::Status;

use crate::input::select::Select;
use crate::output::upsert::Upsert;

pub async fn upsert_selected<I, O, S, U, C>(
    ibucket: I,
    obucket: O,
    sel: &S,
    ups: &U,
    conv: &C,
) -> Result<u64, Status>
where
    S: Select<Bucket = I>,
    U: Upsert<Bucket = O>,
    C: Fn(<S as Select>::Row) -> Result<<U as Upsert>::Row, Status>,
{
    let rows = sel.all(ibucket).await?;

    let converted = rows.map(|r| r.and_then(conv));

    ups.upsert(obucket, converted).await
}