You have to roll this yourself right now with a connection pool of stream objects. I'll probably build this out as a separate module.