Fix ReduceStreams when the input is a normal

Readable, and refactored GroupByStream into a ReduceStream subclass
release 0.0.5