Method read

impit-python/src/response.rs:468–507

(&mut self, py: Python<'_>)

    }

    fn read(&mut self, py: Python<'_>) -> PyResult<Vec<u8>> {
        match self.inner_state {
            InnerResponseState::Read => self
                .content
                .as_ref()
                .cloned()
                .ok_or_else(|| ImpitPyError(impit::errors::ImpitError::ResponseNotRead).into()),
            InnerResponseState::Streaming | InnerResponseState::StreamingClosed => {
                if self.is_stream_consumed {
                    Err(ImpitPyError(impit::errors::ImpitError::StreamConsumed).into())
                } else {
                    Err(ImpitPyError(impit::errors::ImpitError::StreamClosed).into())
                }
            }
            InnerResponseState::Unread => {
                let response = self
                    .inner
                    .take()
                    .ok_or(ImpitPyError(impit::errors::ImpitError::StreamClosed))?;

                let runtime = pyo3_async_runtimes::tokio::get_runtime();
                let content = py.detach(|| {
                    runtime.block_on(async {
                        response
                            .bytes()
                            .await
                            .map(|b| b.to_vec())
                            .map_err(|_| ImpitPyError(impit::errors::ImpitError::NetworkError))
                    })
                })?;

                self.content = Some(content.clone());
                self.inner_state = InnerResponseState::Read;
                self.is_stream_consumed = true;
                self.is_closed = true;

                Ok(content)
            }
        }
    }
}

impl ImpitPyResponse {