SecurityNativeIdManager

StockSharp.Algo

金融商品 ネイティブID処理実装

実装: ISecurityNativeIdManager, IDisposable

コンストラクター

SecurityNativeIdManager
public SecurityNativeIdManager(ILogReceiver logReceiver, INativeIdStorageProvider storageProvider, bool isNativeIdentifiersPersistable)
securityNativeIdManager = SecurityNativeIdManager(logReceiver, storageProvider, isNativeIdentifiersPersistable)

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

logReceiver
ログ受信機。
storageProvider
金融商品名簿記帳プロバイダ。
isNativeIdentifiersPersistable
ネイティブ識別子が永続的かどうか。

メソッド

Dispose
public void Dispose()
securityNativeIdManager.Dispose()

使い捨て可能を実装するプール内のアイテムの処分。

InitializeAsync
public ValueTask InitializeAsync(string storageName, CancellationToken cancellationToken)
result = securityNativeIdManager.InitializeAsync(storageName, cancellationToken)

ストレージプロバイダから初期化

storageName
保管名。
cancellationToken
キャンセルトークン。
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)
result = securityNativeIdManager.ProcessInMessageAsync(message, cancellationToken)

内側のアダプターにメッセージが入ります。

message
投稿する
cancellationToken
キャンセルトークン。

戻り値: 処理結果。

ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[], Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)
result = securityNativeIdManager.ProcessOutMessageAsync(message, cancellationToken)

インナーアダプターからメッセージが届くようにします。

message
メッセージを発信する。
cancellationToken
キャンセルトークン。

戻り値: 処理結果。

イベント

ProcessSuspendedRequested
public event Func<SecurityId, CancellationToken, ValueTask> ProcessSuspendedRequested
securityNativeIdManager.ProcessSuspendedRequested += handler

ストレージやサスペンドメッセージの処理から新しいネイティブIDを追加したときに発生したイベント。