Khwezi Mngoma
13 lines
371 B
C#
13 lines
371 B
C#
using LiteCharms.Features.Abstractions;
|
|
|
|
namespace LiteCharms.Features.ServiceBus.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;
|
|
}
|