Like 'tail -f' but a stream.
Transform an object into another object, as specified by your rejigger rule.
Allows auto-discovery setup of stream topologies.
A module for merging several sorted (ongoing) streams into one.