Module streaming 

Streaming processing module

Provides stream-based node execution with backpressure handling

Re-exports

pub use operators::FilterOperator;

pub use operators::FoldOperator;

pub use operators::MapOperator;

pub use operators::StreamOperator;

pub use stream_node::StreamNode;

Modules

operators

Stream transformation operators

stream_node

Stream-based node implementation

Structs

BackpressureConfig

Backpressure configuration

ChunkConfig

Chunk configuration for large datasets

Traits

StreamProcessor

Stream processor trait

Functions

apply_backpressure

Apply backpressure to a stream Note: This is a placeholder. For full backpressure, use StreamNode with BackpressureConfig

create_chunked_stream

Create a chunked stream from a large dataset

create_stream_from_vec

Create a stream from a vector with backpressure

Type Aliases

StreamItem

Stream item type

ValueStream

Stream type alias