Change: add support for true streams.

Allow results of streaming queries to be piped to other streams.
Add tests for streaming mapreduce.
Refactor code in various places to be more readable.
Update README.md with instructions on streaming back results.