fluxus_api/
lib.rs

1//! Fluxus API - High-level interface for stream processing
2//!
3//! This module provides a user-friendly API for building stream processing applications.
4
5pub mod io;
6pub mod operators;
7pub mod source;
8pub mod stream;
9
10use fluxus_core::{Operator, Source};
11pub use io::{CollectionSink, CollectionSource};
12pub use stream::{DataStream, WindowedStream};
13
14type InnerSource<T> = dyn Source<T> + Send + Sync;
15type InnerOperator<T, R> = dyn Operator<T, R> + Send + Sync;