Added support for DeferredStreams, which allow streams to be collectively composed into much larger structures, all without sacrificing thread safety