FixServerSerializer
StockSharp.Server.Fix
IFixServerSerializer のデフォルト実装。
コンストラクター
FixServerSerializer
public FixServerSerializer(IFixReader reader, IFixWriter writer, IFixWriter bodyWriter, string version, string senderCompId, string targetCompId, FastDateTimeParser dateParser, FastDateTimeParser dateTimeParser, FastTimeSpanParser timeParser, Func<long> getNextId)fixServerSerializer = FixServerSerializer(reader, writer, bodyWriter, version, senderCompId, targetCompId, dateParser, dateTimeParser, timeParser, getNextId)FixServerSerializer の新規インスタンスを初期化します。
- reader
- 受信メッセージの解析を行うFIXリーダー。
- writer
- 発信メッセージを書くFIXライター。
- bodyWriter
- FIX のメッセージ本文のライター。
- version
- FIXプロトコルバージョン。
- senderCompId
- 送信者ID。
- targetCompId
- 対象のコンプリートID。
- dateParser
- デイトパーザー。
- dateTimeParser
- 日/時間パーサー。
- timeParser
- タイムパーサー。
- getNextId
- 次のメッセージシーケンスIDを取得する関数。
プロパティ
メソッド
Convert
protected static string Convert(string value, bool convertToLatin)result = FixServerSerializer.Convert(value, convertToLatin)必要に応じて文字列をラテンに変換します。
ReadBoardLookupAsync
public virtual ValueTask<FixBoardLookup?> ReadBoardLookupAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadBoardLookupAsync(cancellationToken)Read BoardLookup message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadBoardLookupSubscriptionAsync``1
public virtual IAsyncEnumerable<ValueTuple<BoardLookupMessage, string>> ReadBoardLookupSubscriptionAsync<TSession>(TSession session, Func<TSession, string, long> createTransactionId, Func<TSession, string, long> getTransactionId, CancellationToken cancellationToken)result = fixServerSerializer.ReadBoardLookupSubscriptionAsync(session, createTransactionId, getTransactionId, cancellationToken)Read BoardLookup subscription message.
- session
- クライアントセッション。
- createTransactionId
- トランザクションID作成者。
- getTransactionId
- トランザクションIDゲッター。
- cancellationToken
- キャンセルトークン。
戻り値: リクエストIDで、ボードの検索メッセージ。
ReadBoardUpdateAsync
public virtual ValueTask<FixBoardUpdate?> ReadBoardUpdateAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadBoardUpdateAsync(cancellationToken)Read BoardUpdate message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadCommandAsync``2
public virtual IAsyncEnumerable<ValueTuple<TCommandMessage, string>> ReadCommandAsync<TSession, TCommandMessage>(TSession session, Func<TSession, string, long> getTransactionId, Func<FixTags, IFixReader, CancellationToken, ValueTask<bool>> readTag, CancellationToken cancellationToken)result = fixServerSerializer.ReadCommandAsync(session, getTransactionId, readTag, cancellationToken)コマンドメッセージを読む。
ReadDataTypeLookupAsync
public virtual ValueTask<FixDataTypeLookup?> ReadDataTypeLookupAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadDataTypeLookupAsync(cancellationToken)Read DataTypeLookup message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadHeartbeatAsync
public virtual ValueTask<bool> ReadHeartbeatAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadHeartbeatAsync(cancellationToken)ハートビートのメッセージ(メッセージの消費、成功のリターン)をお読みください。
ReadHistoryEndAsync
public virtual ValueTask<bool> ReadHistoryEndAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadHistoryEndAsync(cancellationToken)読みますHistoryEndメッセージ(メッセージ、成功を返します)。
ReadHistoryStartAsync
public virtual ValueTask<FixHistoryStart?> ReadHistoryStartAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadHistoryStartAsync(cancellationToken)Read HistoryStart message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadLogoutAsync
public virtual ValueTask<bool> ReadLogoutAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadLogoutAsync(cancellationToken)ログアウトメッセージ(メッセージの消費、成功の返し)をお読みください。
ReadMarketDataRequestAsync
public virtual IAsyncEnumerable<FixMarketDataRequest> ReadMarketDataRequestAsync(FastDateTimeParser dateParser, CancellationToken cancellationToken)result = fixServerSerializer.ReadMarketDataRequestAsync(dateParser, cancellationToken)Read MarketDataRequest message data.
- dateParser
- 日付/時刻のパーサ
- cancellationToken
- キャンセルトークン。
戻り値: 市場データのリクエストを一括して一括処理可能
ReadNewOrderSingleAsync
public virtual ValueTask<FixNewOrderSingle?> ReadNewOrderSingleAsync(Func<OrderCondition> createCondition, Func<FixTags, Func<OrderCondition>, CancellationToken, ValueTask<bool>> readCondition, CancellationToken cancellationToken)result = fixServerSerializer.ReadNewOrderSingleAsync(createCondition, readCondition, cancellationToken)Read NewOrderSingle message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadNewsAsync
public virtual IAsyncEnumerable<FixNews> ReadNewsAsync(FastDateTimeParser dateParser, CancellationToken cancellationToken)result = fixServerSerializer.ReadNewsAsync(dateParser, cancellationToken)ニュースメッセージのデータをお読みください。
- dateParser
- 日/時間パーサー。
- cancellationToken
- キャンセルトークン。
戻り値: ニュースメッセージ
ReadOrderCancelReplaceRequestAsync
public virtual ValueTask<FixOrderCancelReplaceRequest?> ReadOrderCancelReplaceRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadOrderCancelReplaceRequestAsync(cancellationToken)OrderCancelReplaceRequest メッセージデータを読みます。
戻り値: 読み込まれたときにデータまたはnull。
ReadOrderCancelRequestAsync
public virtual ValueTask<FixOrderCancelRequest?> ReadOrderCancelRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadOrderCancelRequestAsync(cancellationToken)Read OrderCancelRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadOrderConditionAsync
public virtual ValueTask<bool> ReadOrderConditionAsync(FixTags tag, Func<OrderCondition> getCondition, CancellationToken cancellationToken)result = fixServerSerializer.ReadOrderConditionAsync(tag, getCondition, cancellationToken)FIXタグから注文条件を読みます。
ReadOrderMassCancelRequestAsync
public virtual ValueTask<FixOrderMassCancelRequest?> ReadOrderMassCancelRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadOrderMassCancelRequestAsync(cancellationToken)OrderMassCancelRequest メッセージデータを読みます。
戻り値: 読み込まれたときにデータまたはnull。
ReadOrderMassStatusRequestAsync
public virtual ValueTask<FixOrderMassStatusRequest?> ReadOrderMassStatusRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadOrderMassStatusRequestAsync(cancellationToken)OrderMassStatusRequest メッセージデータを読みます。
戻り値: 読み込まれたときにデータまたはnull。
ReadOrderStatusRequestAsync
public virtual ValueTask<FixOrderStatusRequest?> ReadOrderStatusRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadOrderStatusRequestAsync(cancellationToken)Read OrderStatusRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadRemoveAsync
public virtual ValueTask<FixRemove?> ReadRemoveAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadRemoveAsync(cancellationToken)メッセージデータを削除する
戻り値: 読み込まれたときにデータまたはnull。
ReadRequestForPositionsAsync
public virtual ValueTask<FixRequestForPositions?> ReadRequestForPositionsAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadRequestForPositionsAsync(cancellationToken)Read RequestForPositions message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadResendRequestAsync
public virtual ValueTask<FixResendRequest?> ReadResendRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadResendRequestAsync(cancellationToken)Read ResendRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadSecurityLegsRequestAsync
public virtual ValueTask<FixSecurityLegsRequest?> ReadSecurityLegsRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadSecurityLegsRequestAsync(cancellationToken)Read SecurityLegsRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadSecurityListDeleteAsync
public virtual ValueTask<SecurityId[]> ReadSecurityListDeleteAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadSecurityListDeleteAsync(cancellationToken)Read SecurityListDelete message data.
戻り値: 失敗した場合、金融商品IDの削除、またはnullの配列。
ReadSecurityListRequestAsync
public virtual ValueTask<FixSecurityListRequest?> ReadSecurityListRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadSecurityListRequestAsync(cancellationToken)Read SecurityListRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadSecurityListUploadAsync
public virtual IAsyncEnumerable<SecurityMessage> ReadSecurityListUploadAsync(FastDateTimeParser dateParser, FastDateTimeParser yearMonthParser, Action<Exception> logError, CancellationToken cancellationToken)result = fixServerSerializer.ReadSecurityListUploadAsync(dateParser, yearMonthParser, logError, cancellationToken)Read SecurityListUpload messages.
- dateParser
- 日/時間パーサー。
- yearMonthParser
- 年月単位のパーサ。
- logError
- エラーロギングアクション。
- cancellationToken
- キャンセルトークン。
戻り値: 金融商品メッセージ
ReadSecurityMappingAsync
public virtual ValueTask<FixSecurityMapping?> ReadSecurityMappingAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadSecurityMappingAsync(cancellationToken)Read SecurityMapping message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadSecurityStatusRequestAsync
public virtual ValueTask<FixSecurityStatusRequest?> ReadSecurityStatusRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadSecurityStatusRequestAsync(cancellationToken)Read SecurityStatusRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadSequenceResetAsync
public virtual ValueTask<FixSequenceReset?> ReadSequenceResetAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadSequenceResetAsync(cancellationToken)Read SequenceReset message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadSubscriptionRequestAsync``2
public virtual IAsyncEnumerable<ValueTuple<TSubscription, string>> ReadSubscriptionRequestAsync<TSession, TSubscription>(TSession session, Func<TSession, string, long> createTransactionId, Func<TSession, string, long> getTransactionId, Func<TSubscription, FixTags, IFixReader, CancellationToken, ValueTask<bool>> readTag, CancellationToken cancellationToken)result = fixServerSerializer.ReadSubscriptionRequestAsync(session, createTransactionId, getTransactionId, readTag, cancellationToken)一般的なサブスクリプションリクエストをお読みください。
ReadTestRequestAsync
public virtual ValueTask<FixTestRequest?> ReadTestRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadTestRequestAsync(cancellationToken)Read TestRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadTradingSessionStatusRequestAsync
public virtual ValueTask<FixTradingSessionStatusRequest?> ReadTradingSessionStatusRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadTradingSessionStatusRequestAsync(cancellationToken)TradingSessionStatusRequest メッセージデータを読みます。
戻り値: 読み込まれたときにデータまたはnull。
ReadUserInfoAsync
public virtual ValueTask<FixUserInfo?> ReadUserInfoAsync(FastDateTimeParser dateParser, CancellationToken cancellationToken)result = fixServerSerializer.ReadUserInfoAsync(dateParser, cancellationToken)Read UserInfo message data.
- dateParser
- 日/時間パーサー。
- cancellationToken
- キャンセルトークン。
戻り値: 失敗した場合、ユーザ情報データまたはnull。
ReadUserRequestAsync
public virtual ValueTask<FixUserRequest?> ReadUserRequestAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadUserRequestAsync(cancellationToken)Read UserRequest message data.
戻り値: 読み込まれたときにデータまたはnull。
ReadUserRequestExAsync
public virtual ValueTask<FixUserRequestEx?> ReadUserRequestExAsync(CancellationToken cancellationToken)result = fixServerSerializer.ReadUserRequestExAsync(cancellationToken)Read UserRequestEx message data.
戻り値: 読み込まれたときにデータまたはnull。
WriteAsync
public virtual ValueTask WriteAsync(FixUserInfo data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)ユーザ情報を書きます。
WriteAsync
public virtual ValueTask WriteAsync(FixOrderMassCancelReport data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)注文を大量キャンセルレポートに書き込む。
WriteAsync
public virtual ValueTask WriteAsync(FixOrderCancelReject data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)注文キャンセル拒否を書かなければならない。
WriteAsync
public virtual ValueTask WriteAsync(FixExecutionReport data, Func<IFixWriter, OrderCondition, CancellationToken, ValueTask> condition, bool convertToLatin, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, condition, convertToLatin, cancellationToken)実行レポートを書く。
WriteAsync
public virtual ValueTask WriteAsync(FixSubscription data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)サブスクリプションを書く
WriteAsync
public virtual ValueTask WriteAsync(FixSubscriptionOnline data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)オンラインサブスクリプションを書き込みます。
WriteAsync
public virtual ValueTask WriteAsync(FixSubscriptionFinished data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)サブスクリプションの終了を書き込みます。
WriteAsync
public virtual ValueTask WriteAsync(FixSubscriptionResponse data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)サブスクリプションの応答を書き込みます。
WriteAsync
public virtual ValueTask WriteAsync(FixBoard data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)ボードのメッセージを書きます。
WriteAsync
public virtual ValueTask WriteAsync(FixTradingSessionStatus data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)取引セッションのステータスを記述します。
WriteAsync
public virtual ValueTask WriteAsync(FixReject data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)拒否メッセージを書きます。
WriteAsync
public virtual ValueTask WriteAsync(FixLogonResponse data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)ログオン応答を記述します。
WriteAsync
public virtual ValueTask WriteAsync(FixHeartbeat data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)ハートビートの応答を書く。
WriteAsync
public virtual ValueTask WriteAsync(FixSecurityLegsInfo data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)金融商品脚情報を書き込む。
WriteAsync
public virtual ValueTask WriteAsync(FixSecurityListResponseError data, bool convertToLatin, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, convertToLatin, cancellationToken)金融商品リストの応答をエラーで記述します。
WriteAsync
public virtual ValueTask WriteAsync(FixMarketDataSnapshotFullRefresh data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)市場データのスナップショットをフルリフレッシュします。
WriteAsync
public virtual ValueTask WriteAsync(FixMarketDataIncrementalRefresh data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)市場データ増分更新を書く。
WriteAsync
public virtual ValueTask WriteAsync(FixMarketDataRequestReject data, bool convertToLatin, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, convertToLatin, cancellationToken)市場データリクエストの拒否を記述します。
WriteAsync
public virtual ValueTask WriteAsync(FixNews data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)ニュースレターを購読する
WriteAsync
public virtual ValueTask WriteAsync(FixDataTypeInfo data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)データ型情報を書き込む。
WriteAsync
public virtual ValueTask WriteAsync(FixRemoteFile data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)リモートファイルを書きます。
WriteAsync
public virtual ValueTask WriteAsync(FixPositionReport data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)位置レポートを書く。
WriteAsync
public virtual ValueTask WriteAsync(FixSecurityListResponse data, bool convertToLatin, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, convertToLatin, cancellationToken)金融商品リストの応答を書く。
WriteAsync
public virtual ValueTask WriteAsync(FixUserResponse data, CancellationToken cancellationToken)result = fixServerSerializer.WriteAsync(data, cancellationToken)ユーザー応答を書き込みます。
WriteEntriesAsync
protected ValueTask WriteEntriesAsync(IFixWriter writer, ICollection<MDEntry> entries, CancellationToken cancellationToken)result = fixServerSerializer.WriteEntriesAsync(writer, entries, cancellationToken)MD エントリを書く
WriteFixMessageAsync
protected ValueTask WriteFixMessageAsync(string msgType, Func<IFixWriter, CancellationToken, ValueTask> handler, CancellationToken cancellationToken)result = fixServerSerializer.WriteFixMessageAsync(msgType, handler, cancellationToken)指定したメッセージタイプで FIX メッセージを記述します。
- msgType
- FIX メッセージタイプ。
- handler
- メッセージ本文を記述するハンドラ。
- cancellationToken
- キャンセルトークン。
WriteFixOrderConditionAsync
protected virtual ValueTask WriteFixOrderConditionAsync(IFixWriter writer, OrderCondition condition, CancellationToken cancellationToken)result = fixServerSerializer.WriteFixOrderConditionAsync(writer, condition, cancellationToken)FIX注文条件(ストップ/アルゴ注文)を書いてください。
WriteOrderConditionAsync
public virtual ValueTask WriteOrderConditionAsync(OrderCondition condition, CancellationToken cancellationToken)result = fixServerSerializer.WriteOrderConditionAsync(condition, cancellationToken)注文条件(ストップ/注文)を書いて下さい。