Reregister stream with Ready::readable() only in worker.rs
@@ -223,6 +223,8 @@ fn write_to_client(worker: &mut Worker, client_id: Client) {
let buf = client.write_buffer.take().unwrap();
client.stream.write(buf.inner()).unwrap();
+
+ worker.poll.reregister(&client.stream, get_stream_token(client_id), Ready::readable(), PollOpt::edge());
}
fn handle_packet(worker: &mut Worker, client_id: Client, packet: Box<Packet + Send>) {
