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>
; }

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>, 
[src]

Sends everything from a particular source stream to this publisher

Loading content...

Implementors

impl<T: Sized + MessagePublisher> SendStreamToPublisher for T[src]

Loading content...