Skip to main content

fraiseql_wire/stream/
mod.rs

1//! Streaming abstractions
2
3mod adaptive_chunking;
4mod chunking;
5mod filter;
6mod json_stream;
7mod memory_estimator;
8mod query_stream;
9mod typed_stream;
10
11pub use adaptive_chunking::AdaptiveChunking;
12pub use chunking::{ChunkingStrategy, RowChunk};
13pub use filter::{FilteredStream, Predicate};
14pub use json_stream::{extract_json_bytes, parse_json, JsonStream, StreamState, StreamStats};
15pub use memory_estimator::{ConservativeEstimator, FixedEstimator, MemoryEstimator};
16pub use query_stream::QueryStream;
17pub use typed_stream::TypedJsonStream;