tcp-lib 0.1.0

I/O-free library to manage TCP streams
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

/// The TCP I/O state, owned by flows and updated by handlers.
///
/// This struct represents the I/O state used by I/O handlers to take
/// input and set output. It is usually owned by flows themselves, and
/// serve as communication bridge between flows and I/O handlers.
#[derive(Debug)]
pub struct State {
    pub(crate) buffer: Vec<u8>,
    pub(crate) bytes_count: Option<usize>,
}

/// State constructors.
///
/// This implementation gathers functions for building new states.
impl State {
    /// Builds a new state using the given reading capacity.
    ///
    /// See [`State::new`] for building a state with a default reading
    /// capacity.
    pub(crate) fn new(bytes: Vec<u8>) -> Self {
        Self {
            buffer: bytes,
            bytes_count: None,
        }
    }

    pub fn get_buffer(&self) -> &[u8] {
        &self.buffer
    }

    pub fn set_bytes_count(&mut self, bytes_count: usize) {
        self.bytes_count.replace(bytes_count);
    }
}