fn poll_request()

in quic/s2n-quic-transport/src/stream/manager/tests.rs [306:350]

• 35 lines of code
• 10 McCabe index (conditional complexity)

    fn poll_request(
        &mut self,
        request: &mut ops::Request,
        _context: Option<&Context>,
    ) -> Result<ops::Response, StreamError> {
        let mut response = ops::Response::default();

        if let Some(tx) = request.tx.as_ref() {
            if tx.chunks.is_some() {
                self.poll_push_count += 1;
            }

            if tx.finish {
                self.poll_finish_count += 1;
            }

            if tx.reset.is_some() {
                self.reset_count += 1;
            }

            response.tx = Some(ops::tx::Response::default());
        }

        if let Some(rx) = request.rx.as_ref() {
            if rx.chunks.is_some() {
                self.poll_pop_count += 1;
            }

            if rx.stop_sending.is_some() {
                self.stop_sending_count += 1;
            }

            response.rx = Some(ops::rx::Response::default());
        }

        if self.api_call_requires_transmission {
            self.on_transmit_try_write_frames = 1;
        }

        if let Some(err) = self.next_api_error.take() {
            return Err(err);
        }

        Ok(response)
    }