Struct OwnedResultStream 

pub struct OwnedResultStream { /* private fields */ }

Binding-friendly result stream with no lifetime parameter.

Used by language bindings (Python, Node.js, WASM) where Rust lifetimes cannot be expressed at the FFI boundary. The operator tree is 'static because operators hold Arc<dyn GraphStoreSearch> rather than borrows; the stores remain alive as long as the stream does.

Callers that need to tie the stream’s lifetime to something else (e.g. a wrapping Arc<RwLock<GrafeoDB>> in a binding) should carry that keepalive in their own wrapper alongside the stream.

Stability: Experimental

Implementations

impl OwnedResultStream

pub fn columns(&self) -> &[String]

Column names in the order they appear in each row.

pub fn column_types(&self) -> &[LogicalType]

Column types. Initially Any; refined after the first non-empty chunk.

pub fn next_chunk(&mut self) -> Result<Option<DataChunk>>

Pulls the next chunk. See ResultStream::next_chunk.

Errors

Propagates operator errors and deadline timeouts.

pub fn into_row_iter(self) -> OwnedRowIterator

Converts to a row iterator that buffers one chunk internally.

pub fn collect(self) -> Result<QueryResult>

Drains into a QueryResult.

Errors

Propagates operator errors and deadline timeouts.

Trait Implementations

impl Debug for OwnedResultStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.