AsyncMessageChannel

StockSharp.Messages

メッセージをNewOutMessageAsync@に処理するメッセージを同期するチャンネルです。

継承元: Disposable

実装: IMessageChannel, IMessageTransport, IDisposable, ICloneable<IMessageChannel>, ICloneable

コンストラクター

AsyncMessageChannel
public AsyncMessageChannel(IMessageAdapter adapter)
asyncMessageChannel = AsyncMessageChannel(adapter)

メッセージをNewOutMessageAsync@に処理するメッセージを同期するチャンネルです。

adapter
代表取締役社長 佐藤 浩

プロパティ

State
public ChannelStates State { get; private set; }
value = asyncMessageChannel.State
asyncMessageChannel.State = value

ステートストレージの根本的な状態を取得します。

メソッド

Clear
public void Clear()
asyncMessageChannel.Clear()

すべてのアダプターの状態をクリアし、接続解除に現在の状態をリセットします。

Clone
public IMessageChannel Clone()
result = asyncMessageChannel.Clone()

DataSeriesの深いコピーを作成します。

Close
public void Close()
asyncMessageChannel.Close()

定額料金

DisposeManaged
protected override void DisposeManaged()
asyncMessageChannel.DisposeManaged()

リソースのリリース

Open
public void Open()
asyncMessageChannel.Open()

開口価格。

Resume
public void Resume()
asyncMessageChannel.Resume()

履歴書

SendInMessageAsync
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = asyncMessageChannel.SendInMessageAsync(message, cancellationToken)

一般的なメッセージを非同期に処理します。

message
処理するメッセージ。
cancellationToken
担当: 佐藤 宏
Suspend
public void Suspend()
asyncMessageChannel.Suspend()

中断します。.

イベント

NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
asyncMessageChannel.NewOutMessageAsync += handler

新規メッセージイベント

StateChanged
public event Action StateChanged
asyncMessageChannel.StateChanged += handler

状態変更イベント。