Method collect

src/lib.rs:89–110

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

    }

    pub fn collect<'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 res = inner
                .collect(query, config)
                .await
                .context("collect arrow")?;

            let res = convert_response(res).context("convert response to pyarrow")?;

            Ok(res)
        })
    }

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