dope-manifold 0.26.0

Owned application and service composition for dope
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

use core::convert::Infallible;

use o3::base::Call;

/// Send notifications retain their concrete callback and exact input contract.
pub enum Sent<F = Infallible, C = Infallible, P = Infallible, Q = Infallible> {
    None,
    Ready(F),
    Connection(C),
    Pending(P),
    Queue(Q),
}

impl<O, I, P, T, F: Call<O>, C: Call<(O, I, T)>, B: Call<(O, I, P, T)>, Q: Call<(O, I, P)>>
    Call<(O, I, P, T)> for Sent<F, C, B, Q>
{
    fn call(self, (owner, conn, pending, token): (O, I, P, T)) {
        match self {
            Self::None => {}
            Self::Ready(call) => call.call(owner),
            Self::Connection(call) => call.call((owner, conn, token)),
            Self::Pending(call) => call.call((owner, conn, pending, token)),
            Self::Queue(call) => call.call((owner, conn, pending)),
        }
    }
}