Method stream_request

sdk/python/src/lib.rs:1703–1730

Stream a request using the long-lived object-shaped API.

(
        &self,
        py: Python<'_>,
        request: &Bound<'_, PyDict>,
    )

    /// Stream a request using the long-lived object-shaped API.
    fn stream_request(
        &self,
        py: Python<'_>,
        request: &Bound<'_, PyDict>,
    ) -> PyResult<PyEventStream> {
        let (prompt, rust_history, rust_attachments) = py_session_request_to_parts(request)?;
        let session = self.inner.clone();

        let (rx, _handle) = if rust_attachments.is_empty() {
            py.allow_threads(move || {
                get_runtime().block_on(session.stream(&prompt, rust_history.as_deref()))
            })
        } else {
            py.allow_threads(move || {
                get_runtime().block_on(session.stream_with_attachments(
                    &prompt,
                    &rust_attachments,
                    rust_history.as_deref(),
                ))
            })
        }
        .map_err(|e| PyRuntimeError::new_err(format!("Failed to start stream: {e}")))?;

        Ok(PyEventStream {
            rx: Arc::new(Mutex::new(rx)),
            done: Arc::new(AtomicBool::new(false)),
        })
    }

    /// Send a prompt with image attachments and wait for the complete response.
    ///