fn send_request()

in src/worker.rs [246:260]

• 15 lines of code
• 3 McCabe index (conditional complexity)

    fn send_request(&mut self, token: Token, count: usize) -> Result<(), Error> {
        let session = get_session_mut!(self, token)?;
        for _ in 0..count {
            REQUEST.increment();
            self.codec.encode(session);
        }
        session.set_outstanding(count);
        session.set_timestamp(Instant::now());
        let _ = session.flush();
        if session.write_pending() > 0 {
            self.reregister(token)
        } else {
            Ok(())
        }
    }