SecurityNativeIdManager
StockSharp.Algo
金融商品 ネイティブID処理実装
実装: ISecurityNativeIdManager, IDisposable
コンストラクター
SecurityNativeIdManager
public SecurityNativeIdManager(ILogReceiver logReceiver, INativeIdStorageProvider storageProvider, bool isNativeIdentifiersPersistable)
securityNativeIdManager = SecurityNativeIdManager(logReceiver, storageProvider, isNativeIdentifiersPersistable)
SecurityNativeIdManager の新規インスタンスを初期化します。
- logReceiver
- ログ受信機。
- storageProvider
- 金融商品名簿記帳プロバイダ。
- isNativeIdentifiersPersistable
- ネイティブ識別子が永続的かどうか。
メソッド
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を追加したときに発生したイベント。