pipe to a streamsink, and then create readable streams based on that - View it on GitHub