Class AsyncMessageChannel

Namespace

StockSharp.Messages

Assembly

StockSharp.Messages.dll

Async message channel that processes messages via NewOutMessageAsync.

public class AsyncMessageChannel : Disposable, IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable

Inheritance

object

Disposable

AsyncMessageChannel

Implements

IMessageChannel

IMessageTransport

IDisposable

ICloneable<IMessageChannel>

ICloneable

Inherited Members

Disposable.Dispose()

Disposable.DisposeNative()

Disposable.ThrowIfDisposeStarted()

Disposable.ThrowIfDisposed()

Disposable.IsDisposed

Disposable.IsDisposeStarted

Disposable.Disposed

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

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)

Extensions.IsOpened(IMessageChannel)

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)

Remarks

Initializes a new instance of the AsyncMessageChannel.

Constructors

AsyncMessageChannel(IMessageAdapter)

Async message channel that processes messages via NewOutMessageAsync.

public AsyncMessageChannel(IMessageAdapter adapter)

Parameters

adapter IMessageAdapter

IMessageAdapter.

Remarks

Initializes a new instance of the AsyncMessageChannel.

Properties

State

State.

public ChannelStates State { get; }

Property Value

ChannelStates

Methods

Clear()

Clear.

public void Clear()

Clone()

Creates a new object that is a deep copy of the current instance.

public IMessageChannel Clone()

Returns

IMessageChannel

A new object that is a deep copy of this instance.

Close()

Close channel.

public void Close()

DisposeManaged()

Disposes the managed resources. Override this method to add custom clean up of managed resources.

protected override void DisposeManaged()

Open()

Open channel.

public void Open()

Resume()

Resume.

public void Resume()

SendInMessageAsync(Message, CancellationToken)

Processes a generic message asynchronously.

public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

Parameters

message Message

The message to process.

cancellationToken CancellationToken

CancellationToken

Returns

ValueTask

Suspend()

Suspend.

public void Suspend()

Events

NewOutMessageAsync

New message event.

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

Event Type

Func<Message, CancellationToken, ValueTask>

StateChanged

State change event.

public event Action StateChanged

Event Type

Action