pipenet

Non blocking tcp stream wrapper for rust.

use std::net::{TcpStream, SocketAddr};
use serde::{Serialize, Deserialize};
use pipenet::NonBlockStream;

#[derive(Serialize, Deserialize)]
struct MyType {
    x: i32,
    y: i32,
}

let stream = TcpStream::connect(SocketAddr::from(([127, 0, 0, 1], 9999))).unwrap();
let mut nbstream: NonBlockStream<MyType> = stream.into();

// A simple, one time, echo example
if let Some(msg) = nbstream.read().unwrap() {
    nbstream.write(msg).unwrap();
}