[−][src]Trait omnistreams::Consumer

pub trait Consumer<T> {
    fn write(&self, data: T);

    fn end(&self);

    fn event_stream(&mut self) -> Option<ConsumerEventRx>;

    fn set_event_stream(&mut self, event_stream: ConsumerEventRx);
}

Required methods

fn write(&self, data: T)

fn end(&self)

fn event_stream(&mut self) -> Option<ConsumerEventRx>

fn set_event_stream(&mut self, event_stream: ConsumerEventRx)

Loading content...

Implementors

impl Consumer<Vec<u8>> for WriteAdapter[src]

impl Consumer<Vec<u8>> for SinkAdapter[src]

impl<A> Consumer<A> for MapConsumer<A>[src]

impl<A, B> Consumer<A> for MapConduit<A, B>[src]

Loading content...