A wrapper around [futures::Stream] implementing Source trait.
futures::Stream
Source
A handle for emitting messages from Stream::generate.
Stream::generate