IMessageAdapterAsyncExtensions — StockSharp ドキュメント

public static IAsyncEnumerable<T> ConnectAndDownloadAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)

result = IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync(adapter, subscription)

接続、購読、メッセージの非同期ストリームを取得し、完了時に切断します。これは、フルライフサイクルを処理する便利な方法です。接続 - > 購読 - > 切断。

戻り値: メッセージの非同期ストリーム。

ConnectAsync

public static ValueTask ConnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.ConnectAsync(adapter, cancellationToken)

ConnectMessage 経由で IMessageAdapter の Async が接続されます。エラーなしで ConnectMessage を外すと完了します。

戻り値: 担当: 佐藤宏

public static ValueTask DisconnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.DisconnectAsync(adapter, cancellationToken)

DisconnectMessage 経由で IMessageAdapter の非同期接続。エラーなしで DisconnectMessage を外出したときに完了します。

戻り値: 担当: 佐藤宏

public static IAsyncEnumerable<ExecutionMessage> RegisterOrderAndWaitAsync(IMessageAdapter adapter, OrderRegisterMessage order)

result = IMessageAdapterAsyncExtensions.RegisterOrderAndWaitAsync(adapter, order)

注文を登録し、ExecutionMessage(注文状態の変更と独自の取引)の非同期ストリームを取得します。キャンセルトークン(.WithCancellation(トークン)経由)がキャンセルされると、注文は自動的にキャンセルされます。注文が最終的な状態(ドーナまたは失敗)に達した場合完了します。

戻り値: 注文情報と取引でExecutionMessageのAsyncストリーム。

public static ValueTask SubscribeAsync(IMessageAdapter adapter, ISubscriptionMessage subscription, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription, cancellationToken)

購読、開始/終了の待ち、キャンセルされるまで有効に保つ。過去のサブスクリプションは終了したら完了します。キャンセルと退会処理が完了した後にライブが完了します。

戻り値: 担当: 佐藤宏

public static IAsyncEnumerable<T> SubscribeAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription)

指定したタイプのアウトゴングデータメッセージの非同期ストリームを購読して取得します。 .WithCancellation(トークン)を使用して、キャンセルトークンを渡す。

戻り値: メッセージの非同期ストリーム。