tick

使用 eventual Promises 和 Futures 以及 Streams 实现的事件循环Promise和 Stream。

lib.rs:

Tick

mio 上传输、协议和流的实现

示例

use tick::{Tick, Protocol, Transfer};

struct Echo(Transfer);
impl Protocol<Tcp> for Echo {
    fn on_data(&mut self, data: &[u8]) {
        println!("data received: {:?}", data);
        self.0.write(data);
    }
}

let mut tick = Tick::new(Echo);
tick.accept(listener);
tick.run();