Message

/// A message as received by the connection. Provides access to the message
/// header lazily consumes the message body, handling its deserialization.
pub struct Message<'a> {
    pub header: MsgHeader,
    stream: &'a mut Read,
}

Response

/// Response to a `Message`.
pub struct Response<'a> {
    resp_type: Type,
    body: Vec<u8>,
    stream: &'a mut Write,
    attachment: Option<File>,
}

Tracker

pub struct Tracker {
    /// Bytes we've sent.
    pub sent_bytes: Arc<RwLock<RateCounter>>,
    /// Bytes we've received.
    pub received_bytes: Arc<RwLock<RateCounter>>,
    /// Channel to allow sending data through the connection
    pub send_channel: mpsc::SyncSender<Vec<u8>>,
    /// Channel to close the connection
    pub close_channel: mpsc::Sender<()>,
    /// Channel to check for errors on the connection
    pub error_channel: mpsc::Receiver<Error>,
}