Method stream

impit-python/src/async_client.rs:326–369

(
        &self,
        py: Python<'python>,
        method: &str,
        url: String,
        content: Option<Vec<u8>>,
        data: Option<RequestBody>,
        headers: Option<HashMap<String, St

    #[pyo3(signature = (method, url, content=None, data=None, headers=None, timeout=Some(Right(USE_CLIENT_DEFAULT_SENTINEL)), force_http3=false))]
    pub fn stream<'python>(
        &self,
        py: Python<'python>,
        method: &str,
        url: String,
        content: Option<Vec<u8>>,
        data: Option<RequestBody>,
        headers: Option<HashMap<String, String>>,
        timeout: Option<Either<f64, &str>>,
        force_http3: Option<bool>,
    ) -> Result<pyo3::Bound<'python, PyAny>, PyErr> {
        let response = self.request(
            py,
            method,
            url,
            content,
            data,
            headers,
            timeout,
            force_http3,
            Some(true),
        )?;

        let fun: Py<PyAny> = PyModule::from_code(
            py,
            c_str!(
                "def wrap_with_context_manager(response):
            class AsyncContextManager:
                async def __aenter__(self):
                    self.response = await response
                    return self.response
                async def __aexit__(self, exc_type, exc_value, traceback):
                    await self.response.aclose()
            return AsyncContextManager()"
            ),
            c_str!(""),
            c_str!(""),
        )?
        .getattr("wrap_with_context_manager")?
        .into();

        let wrapped_response = fun.call1(py, (response,))?;
        Ok(wrapped_response.into_bound(py))
    }

    #[pyo3(signature = (method, url, content=None, data=None, headers=None, timeout=Some(Right(USE_CLIENT_DEFAULT_SENTINEL)), force_http3=false, stream=false))]
    pub fn request<'python>(