Trait omnistreams::Conduit

pub trait Conduit<A, B>: Consumer<A> + Producer<B> where
    B: Send + 'static, {
    type ConcreteConsumer: Consumer<A>;
    type ConcreteProducer: Producer<B>;
    fn split(self) -> (Self::ConcreteConsumer, Self::ConcreteProducer);
}

Associated Types

type ConcreteConsumer: Consumer<A>

type ConcreteProducer: Producer<B>

Loading content...

Required methods

fn split(self) -> (Self::ConcreteConsumer, Self::ConcreteProducer)

Loading content...

Implementors

impl<A, B> Conduit<A, B> for MapConduit<A, B> where
    B: Send + 'static, 

type ConcreteConsumer = MapConsumer<A>

type ConcreteProducer = MapProducer<B>

fn split(self) -> (MapConsumer<A>, MapProducer<B>)

Loading content...