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(())
}