Method from_stream

perro_source/api_modules/perro_networking/src/tcp.rs:108–120

(stream: TcpStream)

    tx_cursor: usize,
    read_eof: bool,
    disconnect_emitted: bool,
}

impl TcpConnection {
    pub fn connect<A: ToSocketAddrs>(addr: A) -> NetResult<Self> {
        let stream = TcpStream::connect(addr)
            .map_err(|err| NetError::from_io(NetErrorKind::Connect, err))?;
        Self::from_stream(stream)
    }

    pub fn from_stream(stream: TcpStream) -> NetResult<Self> {
        let peer = stream
            .peer_addr()
            .map_err(|err| NetError::from_io(NetErrorKind::PeerAddress, err))?;
        stream
            .set_nonblocking(true)