Trait SubscriberForward 

pub trait SubscriberForward<'a, S> {
    type Output;

    // Required method
    fn forward(&'a mut self, sink: S) -> Self::Output;
}

Allows writing subscriber.forward(receiver) instead of subscriber.stream().map(Ok).forward(publisher)

This API has been marked as unstable: it works as advertised, but it may be changed in a future release.

Required Associated Types

type Output

Required Methods

fn forward(&'a mut self, sink: S) -> Self::Output

Implementations on Foreign Types

impl<'a, S> SubscriberForward<'a, S> for Subscriber<FifoChannelHandler<Sample>>

where S: Sink<Sample>,

type Output = Forward<Map<RecvStream<'a, Sample>, fn(Sample) -> Result<Sample, <S as Sink<Sample>>::Error>>, S>

fn forward(&'a mut self, sink: S) -> Self::Output

Implementors