IMessageQueue

Count

public int Count { get; }

value = iMessageQueue.Count

キューにバッファされたメッセージの現在の数を取得します。

IsClosed

public bool IsClosed { get; }

value = iMessageQueue.IsClosed

キューが閉じられているかどうかを示す値を取得します。

Clear

public void Clear()

iMessageQueue.Clear()

キューからすべてのメッセージを削除します。

Close

public void Close()

iMessageQueue.Close()

キューを閉じて、新しいメッセージが隠されているのを防ぐことができます。

DequeueAsync

public ValueTask<Message> DequeueAsync(CancellationToken cancellationToken)

result = iMessageQueue.DequeueAsync(cancellationToken)

キューから次のメッセージを非同期に削除し、返します。

cancellationToken

キャンセルトークン。

戻り値: キューの次のメッセージ。

Enqueue

public ValueTask Enqueue(Message message, CancellationToken cancellationToken)

result = iMessageQueue.Enqueue(message, cancellationToken)

指定したメッセージの入力

message

問い合わせる

cancellationToken

キャンセルトークン。

Open

public void Open()

iMessageQueue.Open()

キューを開き、キューとディーキューの操作を可能にします。

ReadAllAsync

public IAsyncEnumerable<Message> ReadAllAsync(CancellationToken cancellationToken)

result = iMessageQueue.ReadAllAsync(cancellationToken)

キューからメッセージを生成する非同期の列挙式を返します。

cancellationToken

キャンセルトークン。

戻り値: メッセージのエンメラブルを非同期化