StorageMessageAdapter

StorageMessageAdapter

public StorageMessageAdapter(IMessageAdapter innerAdapter, IStorageProcessor storageProcessor)

storageMessageAdapter = StorageMessageAdapter(innerAdapter, storageProcessor)

ストレージベースのメッセージアダプタ。

innerAdapter

アダプターは、どのメッセージが指示されるかに。

storageProcessor

ストレージプロセッサ。

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = storageMessageAdapter.CloneAsync(cancellationToken)

Create a copy of StorageMessageAdapter.

cancellationToken

CancellationToken

戻り値: Copy.

GetSupportedMarketDataTypesAsync

public override IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)

result = storageMessageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)

アダプターメッセージタイプでサポートを受ける

securityId

担当: 佐藤 宏

from

リクエストの開始日。 場合は、利用可能なすべてのメッセージが返されます。

to

リクエストの終了日。 場合、利用可能なすべてのメッセージが返されます。

戻り値: アダプター市場データ型で対応

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = storageMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

送信する

message

Message.

cancellationToken

CancellationToken