Module stream 

Streaming abstractions

Structs

AdaptiveChunking

Tracks channel occupancy and automatically adjusts chunk size based on backpressure

ChunkingStrategy

Chunking strategy

ConservativeEstimator

Default conservative memory estimator: 2KB per item

FilteredStream

Filtered JSON stream

FixedEstimator

Custom memory estimator using fixed bytes per item

JsonStream

JSON value stream

QueryStream

Query stream with pause/resume/stats capabilities

RowChunk

Row chunk (batch of raw JSON bytes)

StreamStats

Stream statistics snapshot

TypedJsonStream

Typed JSON stream that deserializes rows to type T

Enums

StreamState

Stream state machine

Traits

MemoryEstimator

Trait for estimating memory usage of buffered items

Functions

extract_json_bytes

Extract JSON bytes from DataRow message

parse_json

Parse JSON bytes into Value

Type Aliases

Predicate

Predicate function type