SubscriptionMessageAdapter

StockSharp.Algo

サブスクリプションカウンターアダプター。

継承元: MessageAdapterWrapper

コンストラクター

SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter)

SubscriptionMessageAdapter の新規インスタンスを初期化します。

innerAdapter
内部メッセージのアダプター。
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)

カスタマイズマネージャでSubscriptionMessageAdapterの新規インスタンスを初期化します。

innerAdapter
内部メッセージのアダプター。
manager
サブスクリプションマネージャー。

プロパティ

IsRestoreSubscriptionOnErrorReconnect
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value

再接続でサブスクリプションを復元します。

メソッド

Clone
public override IMessageAdapter Clone()
result = subscriptionMessageAdapter.Clone()

コピーの作成SubscriptionMessageAdapter

戻り値: コピー

InnerAdapterNewOutMessageAsync
protected override ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.InnerAdapterNewOutMessageAsync(message, cancellationToken)

プロセスInnerAdapter@出力メッセージ。

message
メッセージを送信する
cancellationToken
キャンセルトークン。
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

プロセスInnerAdapter@出力メッセージ。

message
メッセージを送信する
cancellationToken
キャンセルトークン。
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

送信する

message
Message.
cancellationToken
CancellationToken