TODO.md

TODO

0.2.0 - Tasks

• Add go module
• Use GitHub Actions CI
• Submit to Awesome-Go
• Add CI/CD badges
  • Build passing, Go Reference, Go Report
  • Awesome-Go
• Add copyright to source files
• Remove dead code
• Signal stream cancellation from error handler ErrorFunc
• Add Stream.OnOpen(func(ctx)) hook to trigger before stream starts
• Add Stream.Notify() to catch os/signal notif

0.2.5

• Automatically turn on batch when batch operators are invoked
• Add support for stream.Into(func(item ){}) which is equivalent to stream.Into(collectors.Func(func))
• Change collectors signature to return StreamError instead of error

0.3 - Tasks

• Stream emitter - source from another stream
• Stream collector - sink into another stream
• New stream operators (join, split, broadcast, etc)
• Parallelization operator
• Add type-specific operators to streams (i.e. SortInt())

0.1 Alpha - Tasks

• Refactor log - implement logging with handler func
• Error propagation and handling strategies
• Support ability to pass context to user-defined operation functions
• Dependency mgmt
• Fix tests with -race failure
• net/htt examples
• Examples with error handling
• Examples with logging
• Context cancellation check for all operators
• Examples with gRPC streaming
• Add logo to README.md
• Rebase commit history