Interface IMessageQueue

Namespace

StockSharp.Messages

Assembly

StockSharp.Messages.dll

Describes a message queue with asynchronous semantics.

public interface IMessageQueue : ICloneable<IMessageQueue>, ICloneable

Inherited Members

ICloneable<IMessageQueue>.Clone()

Extension Methods

AsyncHelper.FromResult<TValue>(TValue)

AsyncHelper.ToCompleteSource<TValue>(TValue)

CompareHelper.IsDefault<T>(T)

CompareHelper.IsRuntimeDefault<T>(T)

Converter.TypedTo<TFrom, TTo>(TFrom)

DelegateHelper.AddDelegate<TDelegate>(TDelegate, TDelegate)

DelegateHelper.GetInvocationList<TDelegate>(TDelegate)

DelegateHelper.RemoveAllDelegates<TDelegate>(TDelegate)

DelegateHelper.RemoveDelegate<TDelegate>(TDelegate, TDelegate)

DisposableHelper.MakeDisposable<T>(T, Action<T>)

Enumerator.IsDefined<T>(T)

Enumerator.SplitMask<T>(T)

NullableHelper.Convert<T, TResult>(T, Func<T, TResult>, Func<TResult>)

NullableHelper.IsNull<T>(T)

NullableHelper.IsNull<T>(T, bool)

TupleHelper.ToValues<T>(T)

TypeHelper.CheckOnNull<T>(T, string)

TypeHelper.DoDispose<TSource>(TSource)

TypeHelper.ToScope<T>(T, bool)

NetworkHelper.Format<T>(T, bool)

PersistableHelper.TrySerialize<T>(T, out SettingsStorage)

XamlHelper.CopyToClipboard<T>(T)

Paths.SerializeToString<T>(T, bool)

Paths.Serialize<T>(T, bool)

Paths.Serialize<T>(T, string, bool)

CompareHelper.Compare(object, object)

Converter.To(object, Type)

Converter.To<T>(object)

Enumerator.GetAttributeOfType<TAttribute>(object)

Enumerator.IsEnumBrowsable(object)

Enumerator.SplitMask2(object)

TypeHelper.HasProperty(object, string)

EntityPropertyHelper.GetPropValue(object, string, Func<object, string, object>, IDictionary<string, object>)

Extensions.GetBasicProperties(object, int)

Extensions.GetDisplayName(object)

Extensions.GetFieldDescription(object)

Extensions.GetFieldDisplayName(object)

Extensions.GetFieldIcon(object)

JsonHelper.ToJson(object, bool)

JsonHelper.ToJson(object, bool, JsonSerializerSettings)

PersistableHelper.ToStorage(object, bool)

EditorExtensions.ToItemsSource(object, Type, bool?, ListSortDirection?, Func<IItemsSourceItem, bool>, Func<object, string>, Func<object, string>)

XamlHelper.EnsureUIThread(object)

XamlHelper.ShowModel<TWindow>(object, DependencyObject)

XamlHelper.WpfCast<T>(object)

VirtualPropertyRegistry.TryGetVirtualValue(object, string, out object)

Properties

Count

Gets the current number of messages buffered in the queue.

int Count { get; }

Property Value

int

IsClosed

Gets a value indicating whether the queue is closed.

bool IsClosed { get; }

Property Value

bool

Methods

Clear()

Removes all messages from the queue.

void Clear()

Close()

Closes the queue and prevents new messages from being enqueued.

void Close()

DequeueAsync(CancellationToken)

Removes and returns the next message from the queue asynchronously.

ValueTask<Message> DequeueAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Cancellation token.

Returns

ValueTask<Message>

The next message in the queue.

Enqueue(Message, CancellationToken)

Enqueues the specified message.

ValueTask Enqueue(Message message, CancellationToken cancellationToken)

Parameters

message Message

The message to enqueue.

cancellationToken CancellationToken

Cancellation token.

Returns

ValueTask

Open()

Opens the queue and allows enqueue and dequeue operations.

void Open()

ReadAllAsync(CancellationToken)

Returns an async enumerable that yields messages from the queue.

IAsyncEnumerable<Message> ReadAllAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Cancellation token.

Returns

IAsyncEnumerable<Message>

Async enumerable of messages.