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;
}