fibers_transport
Transport layer abstraction built on top of fibers
crate.
Examples
UDP peers.
use ;
use ;
type UdpPeer = ;
// Binds peers.
let mut peer0 = execute?;
let peer1 = execute?;
// `peer0` sends a message to `peer1`.
peer0.start_send?;
let peer0 = execute?;
// `peer1` receives a message from `peer0`.
let = execute?;
assert_eq!;
assert_eq!;
TCP server and client.
use ;
use DefaultFactory;
use ;
use Stream;
type TcpServer = ;
type TcpClient = ;
let server = execute?;
let mut client = execute?;
// Sends a message to the server.
client.start_send?;
let client = execute?;
// Receives the message from the client.
let = execute.map_err?;
let server = server.unwrap;
assert_eq!;
let = execute?;
assert_eq!;
// Replies to the client.
server.start_send?;
let _ = execute?;
// Receives the reply from the server.
let = execute?;
assert_eq!;