FixServerSerializer

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

发送者核对身份

targetCompId

目标识别码。

dateParser

日期解说.

dateTimeParser

日期/时间解析器.

timeParser

时解说者.

getNextId

获取下个消息序列ID的函数 。

Reader

public IFixReader Reader { get; }

value = fixServerSerializer.Reader

解析收到信件的 FIX 读取器 。

Writer

public IFixWriter Writer { get; }

value = fixServerSerializer.Writer

FIX 写出外传信件的写作者 。

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.

返回值: 数据失败或读取无效 。

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

交易身份创建者 。

getTransactionId

交易身份识别器。

cancellationToken

取消的代币。

返回值: 带有请求身份的董事会查询信息 。

ReadBoardUpdateAsync

public virtual ValueTask<FixBoardUpdate?> ReadBoardUpdateAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadBoardUpdateAsync(cancellationToken)

Read BoardUpdate message data.

返回值: 数据失败或读取无效 。

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.

返回值: 数据失败或读取无效 。

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.

返回值: 数据失败或读取无效 。

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.

返回值: 数据失败或读取无效 。

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 信件数据 。

返回值: 数据失败或读取无效 。

ReadOrderCancelRequestAsync

public virtual ValueTask<FixOrderCancelRequest?> ReadOrderCancelRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadOrderCancelRequestAsync(cancellationToken)

Read OrderCancelRequest message data.

返回值: 数据失败或读取无效 。

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 信件数据 。

返回值: 数据失败或读取无效 。

ReadOrderMassStatusRequestAsync

public virtual ValueTask<FixOrderMassStatusRequest?> ReadOrderMassStatusRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadOrderMassStatusRequestAsync(cancellationToken)

读取 OrderMassStatusRequest 信件数据 。

返回值: 数据失败或读取无效 。

ReadOrderStatusRequestAsync

public virtual ValueTask<FixOrderStatusRequest?> ReadOrderStatusRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadOrderStatusRequestAsync(cancellationToken)

Read OrderStatusRequest message data.

返回值: 数据失败或读取无效 。

ReadRemoveAsync

public virtual ValueTask<FixRemove?> ReadRemoveAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadRemoveAsync(cancellationToken)

读取信件数据 。

返回值: 数据失败或读取无效 。

ReadRequestForPositionsAsync

public virtual ValueTask<FixRequestForPositions?> ReadRequestForPositionsAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadRequestForPositionsAsync(cancellationToken)

Read RequestForPositions message data.

返回值: 数据失败或读取无效 。

ReadResendRequestAsync

public virtual ValueTask<FixResendRequest?> ReadResendRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadResendRequestAsync(cancellationToken)

Read ResendRequest message data.

返回值: 数据失败或读取无效 。

ReadSecurityLegsRequestAsync

public virtual ValueTask<FixSecurityLegsRequest?> ReadSecurityLegsRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadSecurityLegsRequestAsync(cancellationToken)

Read SecurityLegsRequest message data.

返回值: 数据失败或读取无效 。

ReadSecurityListDeleteAsync

public virtual ValueTask<SecurityId[]> ReadSecurityListDeleteAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadSecurityListDeleteAsync(cancellationToken)

Read SecurityListDelete message data.

返回值: 组合金融工具ID删除, 或读取失败无效 。

ReadSecurityListRequestAsync

public virtual ValueTask<FixSecurityListRequest?> ReadSecurityListRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadSecurityListRequestAsync(cancellationToken)

Read SecurityListRequest message data.

返回值: 数据失败或读取无效 。

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.

返回值: 数据失败或读取无效 。

ReadSecurityStatusRequestAsync

public virtual ValueTask<FixSecurityStatusRequest?> ReadSecurityStatusRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadSecurityStatusRequestAsync(cancellationToken)

Read SecurityStatusRequest message data.

返回值: 数据失败或读取无效 。

ReadSequenceResetAsync

public virtual ValueTask<FixSequenceReset?> ReadSequenceResetAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadSequenceResetAsync(cancellationToken)

Read SequenceReset message data.

返回值: 数据失败或读取无效 。

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.

返回值: 数据失败或读取无效 。

ReadTradingSessionStatusRequestAsync

public virtual ValueTask<FixTradingSessionStatusRequest?> ReadTradingSessionStatusRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadTradingSessionStatusRequestAsync(cancellationToken)

读取 TradingSessionStatusRequest 信件数据 。

返回值: 数据失败或读取无效 。

ReadUserInfoAsync

public virtual ValueTask<FixUserInfo?> ReadUserInfoAsync(FastDateTimeParser dateParser, CancellationToken cancellationToken)

result = fixServerSerializer.ReadUserInfoAsync(dateParser, cancellationToken)

Read UserInfo message data.

dateParser

日期/时间解析器。

cancellationToken

取消的代币。

返回值: 用户信息数据或读取失败时无效 。

ReadUserRequestAsync

public virtual ValueTask<FixUserRequest?> ReadUserRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadUserRequestAsync(cancellationToken)

Read UserRequest message data.

返回值: 数据失败或读取无效 。

ReadUserRequestExAsync

public virtual ValueTask<FixUserRequestEx?> ReadUserRequestExAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadUserRequestExAsync(cancellationToken)

Read UserRequestEx message data.

返回值: 数据失败或读取无效 。

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)

写出订单条件(用于停放/发售订单).