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

取消的代币。

返回值: 信件的可模拟性 。