There is still some instability, but I think the implementation of the essential function is complete 🏋️.
Release
- stateless operators
- Filter
- Foreach
- Map
- FlatMap
- Merge
- Pipe
- To
- stateful operators
- ToTable
- JoinStreamTable
- Aggregate
- Count
- state store
- in memory
- boltDB for persistent
⚠️ unstable
- backpressure strategy
- WithWorkerPool
- WIthBufferedChan
- WithTimeout
- side effect branch
- FailedGStream
- FailedKeyValueGStream