Future to Stream, Streams.defer(future)
Various fixes