Method stream

src/lib.rs:275–294

(
        &'py self,
        query: Query,
        config: StreamConfig,
        py: Python<'py>,
    )

    }

    pub fn stream<'py>(
        &'py self,
        query: Query,
        config: StreamConfig,
        py: Python<'py>,
    ) -> PyResult<Bound<'py, PyAny>> {
        let inner = Arc::clone(&self.inner);

        future_into_py(py, async move {
            let query = query.try_convert().context("parse query")?;
            let config = config.try_convert().context("parse config")?;

            let inner = inner
                .stream(query, config)
                .await
                .context("start inner stream")?;

            Ok(QueryResponseStream::new(inner))
        })
    }

    pub fn stream_events<'py>(
        &'py self,