Skip to content

Instantly share code, notes, and snippets.

Created June 25, 2020 16:54
What would you like to do?
public abstract class EventProcessor<TSourceEvent, TSinkEvent> : EventProcessorBase, IEventProcessor
protected readonly IEventConsumer<TSourceEvent> consumer;
protected readonly IEventProducer<TSinkEvent> producer;
public EventProcessor(
IEventConsumer<TSourceEvent> consumer,
IEventProducer<TSinkEvent> producer,
params IMessageHandler[] handlers)
: base(handlers)
this.consumer = consumer;
this.producer = producer;
public abstract Task Process(CancellationToken cancellationToken = default);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment