1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
#![feature(match_default_bindings)] mod eventloop; mod channel; mod acceptor; extern crate concurrent_hashmap; extern crate mio; #[cfg(test)] mod tests { use std; use std::io::Write; use std::io::Result; use eventloop::*; use channel::*; use acceptor::*; #[test] fn it_works() { Acceptor::new() .worker_count(4) .bind("127.0.0.1", 12345) .handler(Box::new(|ref mut ch| { ch.write("Hello, world.\n".as_bytes()); Ok(()) })) .accept(); std::thread::sleep_ms(100000); } }