Module streaming 

Structs

StreamEvent

A single line from --output-format stream-json output.

Functions

stream_query

Execute a command with streaming output, calling a handler for each NDJSON line.

stream_query_sync

Blocking mirror of stream_query. Reads NDJSON lines from the child’s stdout on a worker thread, dispatches each parsed event to handler on the caller’s thread, and drains stderr on a separate worker thread so the child can’t deadlock on a full pipe.