Trait flo_stream::SendStreamToPublisher

pub trait SendStreamToPublisher: Sized + MessagePublisher {
    fn send_all<'a, SourceStream>(
        &'a mut self, 
        stream: SourceStream
    ) -> StreamPublisher<'a, Self, SourceStream>
    where
        SourceStream: 'a + Stream<Item = Self::Message>;
}

Provides a way to send the values generated by a stream to a publisher

Required methods

Important 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 = ();

fn send_all<'a, SourceStream>(
    &'a mut self,
    stream: SourceStream
) -> StreamPublisher<'a, Self, SourceStream> where
    SourceStream: 'a + Stream<Item = Self::Message>, 

Sends everything from a particular source stream to this publisher

Loading content...

Implementors

impl<T: Sized + MessagePublisher> SendStreamToPublisher for T

Important 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 = ();

fn send_all<'a, SourceStream>(
    &'a mut self,
    stream: SourceStream
) -> StreamPublisher<'a, Self, SourceStream> where
    SourceStream: 'a + Stream<Item = Self::Message>, 

Loading content...