dope-manifold 0.37.0

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

use dope_core::driver::route::Identity;
use dope_net::link::egress::data;

use crate::{
    app::receive::Failure,
    client::{app, close, session::turns},
};

pub(in crate::client::session::app) enum Run {
    Complete,
    Yield,
    Blocked,
    Close,
    Failed(Failure),
}

impl Run {
    pub(in crate::client::session::app) fn finish<
        'e,
        'd,
        C,
        B: data::raw::Payload<'d>,
        ID: Identity,
    >(
        self,
        ctx: &mut turns::Context<'_, 'e, 'd, C, B, ID>,
    ) -> app::Resumed {
        use app::ChunkOutcome;

        let next = match self {
            Self::Close => {
                ctx.request(close::Directive::reconnect(close::Reason::Protocol));
                ChunkOutcome::ok()
            }
            Self::Yield => return app::Resumed::Paused(app::Pause::Yield),
            Self::Blocked => return app::Resumed::Paused(app::Pause::Blocked),
            Self::Failed(cause) => ChunkOutcome::failed(cause),
            Self::Complete => ChunkOutcome::ok(),
        };
        app::Resumed::Complete(next)
    }
}