IOutboundMessageQueue.cs

이 파일의 문서화 페이지로 가기

namespace Dreamine.Communication.Core.Queues;

public interface IOutboundMessageQueue
{
    int Count { get; }

    ValueTask EnqueueAsync(
        QueuedOutboundMessage message,
        CancellationToken cancellationToken = default);

    ValueTask EnqueueFrontAsync(
        QueuedOutboundMessage message,
        CancellationToken cancellationToken = default);

    ValueTask<QueuedOutboundMessage?> TryDequeueAsync(
        CancellationToken cancellationToken = default);

    void Clear();
}