futures::stream::Stream