Trait flo_stream::SendStreamToPublisher [−][src]
pub trait SendStreamToPublisher: Sized + MessagePublisher {
fn send_all<'a, SourceStream>(
&'a mut self,
stream: SourceStream
) -> StreamPublisher<'a, Self, SourceStream>ⓘNotable traits for StreamPublisher<'a, Publisher, SourceStream>impl<'a, Publisher, SourceStream> Future for StreamPublisher<'a, Publisher, SourceStream> where
Publisher: MessagePublisher,
SourceStream: Stream<Item = Publisher::Message>, type Output = ();
where
SourceStream: 'a + Stream<Item = Self::Message>;
}Expand description
Provides a way to send the values generated by a stream to a publisher
Required methods
fn send_all<'a, SourceStream>(
&'a mut self,
stream: SourceStream
) -> StreamPublisher<'a, Self, SourceStream>ⓘNotable traits for StreamPublisher<'a, Publisher, SourceStream>impl<'a, Publisher, SourceStream> Future for StreamPublisher<'a, Publisher, SourceStream> where
Publisher: MessagePublisher,
SourceStream: Stream<Item = Publisher::Message>, type Output = (); where
SourceStream: 'a + Stream<Item = Self::Message>,
fn send_all<'a, SourceStream>(
&'a mut self,
stream: SourceStream
) -> StreamPublisher<'a, Self, SourceStream>ⓘNotable traits for StreamPublisher<'a, Publisher, SourceStream>impl<'a, Publisher, SourceStream> Future for StreamPublisher<'a, Publisher, SourceStream> where
Publisher: MessagePublisher,
SourceStream: Stream<Item = Publisher::Message>, type Output = (); where
SourceStream: 'a + Stream<Item = Self::Message>,
Notable traits for StreamPublisher<'a, Publisher, SourceStream>
impl<'a, Publisher, SourceStream> Future for StreamPublisher<'a, Publisher, SourceStream> where
Publisher: MessagePublisher,
SourceStream: Stream<Item = Publisher::Message>, type Output = ();Sends everything from a particular source stream to this publisher