v0.1.0

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