volans-core 0.2.0

Core trait and struct for Volans networking framework
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

mod apply;
mod denied;
mod either;
mod error;
mod pending;
mod ready;
mod select;

pub use apply::{InboundUpgradeApply, OutboundUpgradeApply, apply};
pub use denied::DeniedUpgrade;
pub use error::UpgradeError;
pub use pending::PendingUpgrade;
pub use ready::ReadyUpgrade;
pub use select::SelectUpgrade;

/// 升级信息
pub trait UpgradeInfo {
    type Info: AsRef<str> + Clone;
    type InfoIter: Iterator<Item = Self::Info>;

    fn protocol_info(&self) -> Self::InfoIter;
}

pub trait InboundUpgrade<C>: UpgradeInfo {
    type Output;
    type Error;
    type Future: Future<Output = Result<Self::Output, Self::Error>>;

    /// 升级入站流
    fn upgrade_inbound(self, socket: C, info: Self::Info) -> Self::Future;
}

pub trait OutboundUpgrade<C>: UpgradeInfo {
    type Output;
    type Error;
    type Future: Future<Output = Result<Self::Output, Self::Error>>;

    /// 升级出站流
    fn upgrade_outbound(self, socket: C, info: Self::Info) -> Self::Future;
}

pub trait InboundConnectionUpgrade<C>: UpgradeInfo {
    type Output;
    type Error;
    type Future: Future<Output = Result<Self::Output, Self::Error>>;

    fn upgrade_inbound(self, socket: C, info: Self::Info) -> Self::Future;
}

pub trait OutboundConnectionUpgrade<C>: UpgradeInfo {
    type Output;
    type Error;
    type Future: Future<Output = Result<Self::Output, Self::Error>>;

    fn upgrade_outbound(self, socket: C, info: Self::Info) -> Self::Future;
}