CandleBuilderManager
StockSharp.Algo.Candles.Compression
キャンドルビルダーの処理実装。
コンストラクター
CandleBuilderManager
public CandleBuilderManager(ILogReceiver logReceiver, IdGenerator idGenerator, IMessageAdapterWrapper adapter, bool sendFinishedCandlesImmediatelly, IStorageBuffer buffer, bool cloneOutCandles, CandleBuilderProvider candleBuilderProvider)candleBuilderManager = CandleBuilderManager(logReceiver, idGenerator, adapter, sendFinishedCandlesImmediatelly, buffer, cloneOutCandles, candleBuilderProvider)CandleBuilderManager の新規インスタンスを初期化します。
- logReceiver
- ログ受信機。
- idGenerator
- トランザクションIDジェネレータ。
- adapter
- ループバックメッセージと内部アダプターアクセスに使用されるアダプターラッパー。
- sendFinishedCandlesImmediatelly
- すぐに完成したキャンドルを送信します。
- buffer
- ストレージバッファ。
- cloneOutCandles
- 出入り口前にキャンドルをクローニングする必要があるかどうかを指示します。
- candleBuilderProvider
- キャンドルビルダープロバイダ。
プロパティ
Buffer
public IStorageBuffer Buffer { get; set; }value = candleBuilderManager.Buffer
candleBuilderManager.Buffer = valueストレージバッファ。
SendFinishedCandlesImmediatelly
public bool SendFinishedCandlesImmediatelly { get; set; }value = candleBuilderManager.SendFinishedCandlesImmediatelly
candleBuilderManager.SendFinishedCandlesImmediatelly = value受け取ったときに終了したキャンドルを送信します。
メソッド
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = candleBuilderManager.ProcessInMessageAsync(message, cancellationToken)内側のアダプターにメッセージが入ります。
- message
- 投稿する
- cancellationToken
- キャンセルトークン。
戻り値: 処理結果。
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = candleBuilderManager.ProcessOutMessageAsync(message, cancellationToken)インナーアダプターからメッセージが届くようにします。
- message
- メッセージを発信する。
- cancellationToken
- キャンセルトークン。
戻り値: 処理結果。