IMessageQueue

Count : int

Gets the current number of messages buffered in the queue.

IsClosed : bool

Gets a value indicating whether the queue is closed.

Clear()

Removes all messages from the queue.

Close()

Closes the queue and prevents new messages from being enqueued.

DequeueAsync(CancellationToken) : ValueTask<Message>

Removes and returns the next message from the queue asynchronously.

cancellationToken

Cancellation token.

Rückgabe: The next message in the queue.

Enqueue(Message, CancellationToken) : ValueTask

Enqueues the specified message.

message

The message to enqueue.

cancellationToken

Cancellation token.

Open()

Opens the queue and allows enqueue and dequeue operations.

ReadAllAsync(CancellationToken) : IAsyncEnumerable<Message>

Returns an async enumerable that yields messages from the queue.

cancellationToken

Cancellation token.

Rückgabe: Async enumerable of messages.