Skip to content

Instantly share code, notes, and snippets.

@tonysneed
Created June 25, 2020 16:54
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tonysneed/9e1425bc95754ba41c87380d43a462b9 to your computer and use it in GitHub Desktop.
Save tonysneed/9e1425bc95754ba41c87380d43a462b9 to your computer and use it in GitHub Desktop.
EventProcessor
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