msg-socket 0.1.6

Sockets for msg-rs
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

/// Abstraction to represent the state of a connection.
///
/// * `C` is the channel type, which is used to send and receive generic messages.
/// * `B` is the backoff type, used to control the backoff state for inactive connections.
/// * `A` is the address type, used to represent the address of the connection.
pub enum ConnectionState<C, B, A> {
    Active {
        /// Channel to control the underlying connection. This is used to send
        /// and receive any kind of message in any direction.
        channel: C,
    },
    Inactive {
        addr: A,
        /// The current backoff state for inactive connections.
        backoff: B,
    },
}

impl<C, B, A> ConnectionState<C, B, A> {
    /// Returns `true` if the connection is active.
    pub fn is_active(&self) -> bool {
        matches!(self, Self::Active { .. })
    }

    /// Returns `true` if the connection is inactive.
    pub fn is_inactive(&self) -> bool {
        matches!(self, Self::Inactive { .. })
    }
}