in src/worker.rs [320:326]
fn do_write(&mut self, token: Token) -> Result<(), Error> { let session = get_session_mut!(self, token)?; if session.write_pending() > 0 { session.flush()?; } Ok(()) }