mutant-pull-reduce

Reduce the output of a pull-stream into a mutant observable.