Khwezi Mngoma
acc0d44c7c
Internal service bus support enabled Added quartz support Reconfigured extensions
11 lines
310 B
C#
11 lines
310 B
C#
namespace LiteCharms.Abstractions;
|
|
|
|
public abstract class EventBusQueueBase
|
|
{
|
|
protected readonly Channel<IEvent> channel = Channel.CreateBounded<IEvent>(Constants.QueueBounds);
|
|
|
|
public ChannelWriter<IEvent> Outgoing => channel.Writer;
|
|
|
|
public ChannelReader<IEvent> Incoming => channel.Reader;
|
|
}
|