Skip to main content

laminar_core/streaming/
mod.rs

1//! In-memory streaming API — Source, Sink, Subscription with broadcast fan-out.
2
3pub mod channel;
4pub mod checkpoint;
5pub mod config;
6pub mod error;
7pub mod sink;
8pub mod source;
9pub mod subscription;
10
11pub use channel::{channel, AsyncConsumer, Producer};
12pub use checkpoint::{CheckpointError, StreamCheckpointConfig};
13pub use config::{BackpressureStrategy, ChannelConfig, SourceConfig, WaitStrategy};
14pub use error::{RecvError, StreamingError, TryPushError};
15pub use sink::Sink;
16pub use source::{create, create_with_config, Record, Source};
17pub use subscription::Subscription;