BaseMessageQueue

StockSharp.Messages

Базовая реализация IMessageQueue.

Наследует: BaseOrderedChannel<long, Message, PriorityQueue<long, Message>>

Реализует: IMessageQueue, ICloneable<IMessageQueue>, ICloneable

Конструкторы

BaseMessageQueue
protected BaseMessageQueue()
baseMessageQueue = BaseMessageQueue()

Базовая реализация IMessageQueue.

Методы

Clone
public abstract IMessageQueue Clone()
result = baseMessageQueue.Clone()

Создает глубокую копию DataSeries.

Enqueue
public abstract ValueTask Enqueue(Message message, CancellationToken cancellationToken)
result = baseMessageQueue.Enqueue(message, cancellationToken)

Ставит указанное сообщение в очередь.

message
Сообщение для постановки в очередь.
cancellationToken
Токен отмены.