Contains utility methods to create StreamTransfomer instances to manipulate Streams.
StreamTransfomer
Collects values from a source stream until a trigger stream fires and the collected values are emitted.
trigger