Added support for closing readable streams.
Removed empty lines
Bumped mqemitter dependency to 0.2.0