fn do_write()

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