Struct TcpStreamThread

pub struct TcpStreamThread {
    pub stream_thread: Option<JoinHandle<()>>,
    pub task_tx: Sender<Task>,
    pub reader_rx: Receiver<Vec<u8>>,
    pub readable_registration: Registration,
    pub reader_events: Events,
    /* private fields */
}

Fields

stream_thread: Option<JoinHandle<()>>

task_tx: Sender<Task>

reader_rx: Receiver<Vec<u8>>

readable_registration: Registration

reader_events: Events

Implementations

impl TcpStreamThread

pub fn new(tcp_stream: TcpStream) -> Result<Self, Error>

pub fn recv(&mut self, size: usize) -> Result<Vec<u8>, Error>

pub fn send(&mut self, data: Vec<u8>) -> Result<(), SendError<Task>>

pub fn close(&mut self)