Class StudioChannel

Namespace

StockSharp.Studio.IPC

Assembly

StockSharp.Studio.IPC.dll

Message channel between S# applications.

public class StudioChannel : BaseLogReceiver, IPersistable, ILogReceiver, ILogSource, IDisposable

Inheritance

object

Disposable

BaseLogSource

BaseLogReceiver

StudioChannel

Implements

IPersistable

ILogReceiver

ILogSource

IDisposable

Inherited Members

BaseLogReceiver.LogVerbose(string, params object[])

BaseLogReceiver.LogDebug(string, params object[])

BaseLogReceiver.LogInfo(string, params object[])

BaseLogReceiver.LogWarning(string, params object[])

BaseLogReceiver.LogError(string, params object[])

BaseLogReceiver.LogError(Exception)

BaseLogSource.RaiseLog(LogMessage)

BaseLogSource.ToString()

BaseLogSource.Load(SettingsStorage)

BaseLogSource.Save(SettingsStorage)

BaseLogSource.Id

BaseLogSource.Name

BaseLogSource.Parent

BaseLogSource.LogLevel

BaseLogSource.CurrentTime

BaseLogSource.IsRoot

BaseLogSource.ParentRemoved

BaseLogSource.Log

Disposable.Dispose()

Disposable.DisposeNative()

Disposable.ThrowIfDisposeStarted()

Disposable.ThrowIfDisposed()

Disposable.IsDisposed

Disposable.IsDisposeStarted

Disposable.Disposed

object.GetType()

object.MemberwiseClone()

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)

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)

Constructors

StudioChannel(long, ISerializer<SettingsStorage>, Func<StudioMessage, CancellationToken, ValueTask<StudioMessage>>, ILogSource, Func<bool>)

Create instance.

public StudioChannel(long channelId, ISerializer<SettingsStorage> serializer, Func<StudioMessage, CancellationToken, ValueTask<StudioMessage>> handler, ILogSource parent, Func<bool> tryStartReceiver)

Parameters

channelId long

This product.

serializer ISerializer<SettingsStorage>

Serializer.

handler Func<StudioMessage, CancellationToken, ValueTask<StudioMessage>>

Incoming message handler.

parent ILogSource

tryStartReceiver Func<bool>

Methods

DisposeManaged()

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

protected override void DisposeManaged()

GetResponseAsync(StudioMessage, long, CancellationToken)

Send message and get response asynchonously.

public Task<StudioMessage> GetResponseAsync(StudioMessage message, long toProductId, CancellationToken token)

Parameters

message StudioMessage

toProductId long

token CancellationToken

Returns

Task<StudioMessage>

RunServerAsync(CancellationToken)

public Task RunServerAsync(CancellationToken token)

Parameters

token CancellationToken

Returns

Task

SendAsync(StudioMessage, long, CancellationToken)

public Task SendAsync(StudioMessage message, long toProductId, CancellationToken token)

Parameters

message StudioMessage

toProductId long

token CancellationToken

Returns

Task