dope-net 0.39.0

Owned network transports 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

use dope_core::driver::receive::credit::error::Arm;

use crate::{
    link::duplex,
    wire::{self, receive, send},
};

mod io;
pub(in crate::link) mod recv;
pub mod transmit;
pub mod types;

pub use io::Io;

type Engine<'d, ID, W> = duplex::Duplex<
    'd,
    ID,
    <<W as wire::Spec>::Receive as receive::Policy<W>>::Discard,
    <<W as wire::Spec>::Send as send::Policy<W>>::Reclaim,
>;

pub(in crate::link) enum Decision<C> {
    Control(Control),
    Chunk { chunk: C, needs_rearm: bool },
}

pub(in crate::link) enum Control {
    Eof,
    Cancelled,
    Failed(dope_core::Errno),
    Credit { cause: Arm, needs_rearm: bool },
    NoChunk { needs_rearm: bool },
    Discarded { needs_rearm: bool, finished: bool },
}