tokio love

listener_test.rs

extern crate tokio_io;
extern crate tokio_core;
extern crate futures;

use tokio_core::reactor::Core;
use std::net::SocketAddr;
use tokio_core::net::TcpListener;
use tokio_core::net::TcpStream;
use futures::Future;
use futures::Stream;
use std::error::Error as StdError;

#[test]
fn test_tcp_listener() {
    let mut core = Core::new().unwrap();
    let handle = core.handle();

    let addr: SocketAddr = "127.0.0.1:8000".parse().unwrap();

    let handle_cloned = handle.clone();

    let fut_stream = TcpListener::bind(&addr, &handle_cloned).unwrap();
    let fut = fut_stream.incoming()
        .for_each(move |(stream, _)| {
            println!("connected!");
            Ok(())
        })
        .map_err(log_error);

    handle.spawn(fut);

    let stream = TcpStream::connect(&addr, &handle_cloned);
    let res =  core.run(stream);
}

pub fn log_error<E: StdError>(err: E) {
    println!("An error occurred: {}", err)
}