streamulus
streamulus copied to clipboard
Refactor strop_func::Work()
- The Stream should have timestamps so that ticks are combined correctly even in situations like x+filter(x).
- Merging input streams should happen in a separate class so that different merge methods can be implemented, such as a coalesce version. Also, if there is no need to timestamp resolution (single input or user hint), it can be skipped.