Struct PythonStream 

pub struct PythonStream { /* private fields */ }

A handle to an in-flight Python server-stream — the iterator obtained by calling a streaming plugin method.

Send (a Py<PyAny> is Send + Sync) so the host can drive it from a dedicated pump thread, acquiring the GIL only for each next/cancel.

Implementations

impl PythonStream

pub fn next(&self) -> PyStreamStep

Advance one item. Holds the GIL only for the duration of this call, so a slow downstream consumer never pins the interpreter.

pub fn cancel(&self)

Cancel the stream: run the generator’s cleanup by calling close(), which raises GeneratorExit inside the generator so its finally/ context-manager __exit__ runs (closing DB cursors, releasing handles). A no-op for iterables without close (e.g. a plain list_iterator).