transaction 0.2.1

transaction abstraction library (a.k.a. transaction monad)
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

use {IntoTransaction, Transaction};

/// join a vec of transaction
pub fn join_all<Ctx, I, B>(i: I) -> JoinAll<B::Tx>
where
    I: IntoIterator<Item = B>,
    B: IntoTransaction<Ctx>,
{
    JoinAll {
        vec: i.into_iter()
            .map(IntoTransaction::into_transaction)
            .collect(),
    }
}

/// The result of `join_vec`
#[derive(Debug)]
#[must_use]
pub struct JoinAll<Tx> {
    vec: Vec<Tx>,
}

impl<Tx> Transaction for JoinAll<Tx>
where
    Tx: Transaction,
{
    type Ctx = Tx::Ctx;
    type Item = Vec<Tx::Item>;
    type Err = Tx::Err;

    fn run(&self, ctx: &mut Self::Ctx) -> Result<Self::Item, Self::Err> {
        let vec = &self.vec;

        vec.iter()
            .map(|tx| tx.run(ctx))
            .collect::<Result<Vec<_>, _>>()
    }
}