dope-manifold 0.36.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

use std::convert;

use dope_net::wire::{
    self,
    receive::{self, batch::Items},
};

use crate::app::receive::{Outcome, ingress::Progress};

mod grant;

pub(crate) use grant::Grant;

pub(crate) fn drive<'input, W, F>(
    mut items: Items<'input, W>,
    mut recv: F,
) -> Progress<convert::Infallible>
where
    W: wire::Spec,
    F: FnMut(
        <<W::Receive as receive::Policy<W>>::Batch<'input> as receive::raw::Batch<'input>>::Item,
    ) -> Outcome,
{
    for item in &mut items {
        match recv(item) {
            Outcome::Continue => {}
            done @ (Outcome::CloseAfter | Outcome::Failed(_)) => return Progress::Done(done),
        }
    }
    Progress::Done(Outcome::Continue)
}