Rename collect() to buffer() to align with rx
Add elapsed(), benchmarking between two data signals
Add limit(), a stop condition for streams
Add sort(), a staging priorityQueue to reorder a stream
Add timestamp(), a given time for each signal