fluxus-api 0.2.0

High-level API for Fluxus stream processing engine
Documentation 
1
2
3
4
5
6
7
8
9
10

//! Fluxus API - High-level interface for stream processing
//!
//! This module provides a user-friendly API for building stream processing applications.

pub mod io;
pub mod operators;
pub mod stream;

pub use io::{CollectionSink, CollectionSource};
pub use stream::{DataStream, WindowedStream};