Trait rust_transit::Consumer

pub trait Consumer<T: EventType>: ConsumerGroup {
    fn consume(&self, t: GenericEvent<T>) -> Result<(), ()>;
}

Consumer trait defining what to do with the event

Required methods

fn consume(&self, t: GenericEvent<T>) -> Result<(), ()>

Loading content...

Implementors

impl Consumer<StringEvent> for StringAccumulateConsumer

Implementation of Consumer

fn consume(&self, t: GenericEvent<StringEvent>) -> Result<(), ()>

Loading content...