You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Typed source-transform-sink pipelines with backpressure, batching, windowing, and per-stage error isolation. A lightweight runtime-agnostic stream processor for in-process workloads. The missing middle ground between raw iterators and full distributed stream processing.
24
25
26
+
## Quick start
27
+
28
+
```rust
29
+
usepipe_io::{Pipeline, sink::VecSink};
30
+
31
+
letsink=VecSink::<i64>::new();
32
+
lethandle=sink.handle();
33
+
34
+
Pipeline::from_iter(1..=5)
35
+
.map(|n:i32|i64::from(n) *10)
36
+
.filter(|n:&i64|*n>20)
37
+
.sink(sink)
38
+
.run()
39
+
.expect("pipeline run");
40
+
41
+
assert_eq!(handle.take(), vec![30, 40, 50]);
42
+
```
43
+
44
+
## Documentation
45
+
46
+
-[Quick reference (`docs/API.md`)](docs/API.md)
47
+
-[User guide (`docs/GUIDE.md`)](docs/GUIDE.md) - patterns and how-tos
48
+
-[Project specification (`REPS.md`)](REPS.md) - locked public surface
0 commit comments