Refactor some code and provide ability to write datastreams