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)

Inicializa uma nova instância do FixServerSerializer.

reader

O leitor FIX para processar mensagens recebidas.

writer

O escritor FIX para escrever mensagens enviadas.

bodyWriter

O escritor FIX para o corpo de mensagem.

version

A versão do protocolo FIX.

senderCompId

A identificação do remetente.

targetCompId

A identificação do alvo.

dateParser

O analisador de encontros.

dateTimeParser

O analisador data/hora.

timeParser

O analisador do tempo.

getNextId

Função para obter a próxima sequência de mensagens ID.

Reader

public IFixReader Reader { get; }

value = fixServerSerializer.Reader

O leitor FIX para processar mensagens recebidas.

Writer

public IFixWriter Writer { get; }

value = fixServerSerializer.Writer

O escritor FIX para escrever mensagens enviadas.

Convert

protected static string Convert(string value, bool convertToLatin)

result = FixServerSerializer.Convert(value, convertToLatin)

Converta texto para latim, se necessário.

ReadBoardLookupAsync

public virtual ValueTask<FixBoardLookup?> ReadBoardLookupAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadBoardLookupAsync(cancellationToken)

Leia BoardLookup message data.

Retorna: Dados ou nulos se lidos falhou.

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)

Leia BoardLookup subscription message.

session

Sessão de cliente.

createTransactionId

Criador de ID de transação.

getTransactionId

Identificador de transação.

cancellationToken

Inscrição de cancelamento.

Retorna: Mensagens de procura do tabuleiro com IDs de solicitação.

ReadBoardUpdateAsync

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

result = fixServerSerializer.ReadBoardUpdateAsync(cancellationToken)

Leia BoardUpdate message data.

Retorna: Dados ou nulos se lidos falhou.

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)

Leia a mensagem do Comando.

ReadDataTypeLookupAsync

public virtual ValueTask<FixDataTypeLookup?> ReadDataTypeLookupAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadDataTypeLookupAsync(cancellationToken)

Leia DataTypeLookup message data.

Retorna: Dados ou nulos se lidos falhou.

ReadHeartbeatAsync

public virtual ValueTask<bool> ReadHeartbeatAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHeartbeatAsync(cancellationToken)

Leia a mensagem Heartbeat (consume a mensagem, retorna o sucesso).

ReadHistoryEndAsync

public virtual ValueTask<bool> ReadHistoryEndAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHistoryEndAsync(cancellationToken)

Leia HistoryEnd message (consumes message, retorna o sucesso).

ReadHistoryStartAsync

public virtual ValueTask<FixHistoryStart?> ReadHistoryStartAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHistoryStartAsync(cancellationToken)

Leia HistoryStart message data.

Retorna: Dados ou nulos se lidos falhou.

ReadLogoutAsync

public virtual ValueTask<bool> ReadLogoutAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadLogoutAsync(cancellationToken)

Ler a mensagem de saída (consumo mensagem, retorna o sucesso).

ReadMarketDataRequestAsync

public virtual IAsyncEnumerable<FixMarketDataRequest> ReadMarketDataRequestAsync(FastDateTimeParser dateParser, CancellationToken cancellationToken)

result = fixServerSerializer.ReadMarketDataRequestAsync(dateParser, cancellationToken)

Leia MarketDataRequest message data.

dateParser

Data/hora do analisador para os campos de data.

cancellationToken

Inscrição de cancelamento.

Retorna: Sincronização enumerável de pedidos de dados de mercado.

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)

Leia NewOrderSingle message data.

Retorna: Dados ou nulos se lidos falhou.

ReadNewsAsync

public virtual IAsyncEnumerable<FixNews> ReadNewsAsync(FastDateTimeParser dateParser, CancellationToken cancellationToken)

result = fixServerSerializer.ReadNewsAsync(dateParser, cancellationToken)

Leia os dados da mensagem de notícias.

dateParser

Data/hora analisador.

cancellationToken

Inscrição de cancelamento.

Retorna: Mensagens de notícias.

ReadOrderCancelReplaceRequestAsync

public virtual ValueTask<FixOrderCancelReplaceRequest?> ReadOrderCancelReplaceRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadOrderCancelReplaceRequestAsync(cancellationToken)

Leia OrderCancelReplaceRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadOrderCancelRequestAsync

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

result = fixServerSerializer.ReadOrderCancelRequestAsync(cancellationToken)

Leia OrderCancelRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadOrderConditionAsync

public virtual ValueTask<bool> ReadOrderConditionAsync(FixTags tag, Func<OrderCondition> getCondition, CancellationToken cancellationToken)

result = fixServerSerializer.ReadOrderConditionAsync(tag, getCondition, cancellationToken)

Leia a condição de ordem de etiquetas FIX.

ReadOrderMassCancelRequestAsync

public virtual ValueTask<FixOrderMassCancelRequest?> ReadOrderMassCancelRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadOrderMassCancelRequestAsync(cancellationToken)

Leia OrderMassCancelRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadOrderMassStatusRequestAsync

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

result = fixServerSerializer.ReadOrderMassStatusRequestAsync(cancellationToken)

Leia OrderMassStatusRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadOrderStatusRequestAsync

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

result = fixServerSerializer.ReadOrderStatusRequestAsync(cancellationToken)

Leia OrderStatusRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadRemoveAsync

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

result = fixServerSerializer.ReadRemoveAsync(cancellationToken)

Ler Remover dados da mensagem.

Retorna: Dados ou nulos se lidos falhou.

ReadRequestForPositionsAsync

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

result = fixServerSerializer.ReadRequestForPositionsAsync(cancellationToken)

Leia RequestForPositions message data.

Retorna: Dados ou nulos se lidos falhou.

ReadResendRequestAsync

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

result = fixServerSerializer.ReadResendRequestAsync(cancellationToken)

Leia ResendRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadSecurityLegsRequestAsync

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

result = fixServerSerializer.ReadSecurityLegsRequestAsync(cancellationToken)

Leia SecurityLegsRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadSecurityListDeleteAsync

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

result = fixServerSerializer.ReadSecurityListDeleteAsync(cancellationToken)

Leia SecurityListDelete message data.

Retorna: Array de IDs de instrumento financeiro para excluir, ou null se lido falhou.

ReadSecurityListRequestAsync

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

result = fixServerSerializer.ReadSecurityListRequestAsync(cancellationToken)

Leia SecurityListRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadSecurityListUploadAsync

public virtual IAsyncEnumerable<SecurityMessage> ReadSecurityListUploadAsync(FastDateTimeParser dateParser, FastDateTimeParser yearMonthParser, Action<Exception> logError, CancellationToken cancellationToken)

result = fixServerSerializer.ReadSecurityListUploadAsync(dateParser, yearMonthParser, logError, cancellationToken)

Leia SecurityListUpload messages.

dateParser

Data/hora analisador.

yearMonthParser

Analisador de ano.

logError

Erro ao registrar a ação.

cancellationToken

Inscrição de cancelamento.

Retorna: mensagens de instrumentos financeiros.

ReadSecurityMappingAsync

public virtual ValueTask<FixSecurityMapping?> ReadSecurityMappingAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadSecurityMappingAsync(cancellationToken)

Leia SecurityMapping message data.

Retorna: Dados ou nulos se lidos falhou.

ReadSecurityStatusRequestAsync

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

result = fixServerSerializer.ReadSecurityStatusRequestAsync(cancellationToken)

Leia SecurityStatusRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadSequenceResetAsync

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

result = fixServerSerializer.ReadSequenceResetAsync(cancellationToken)

Leia SequenceReset message data.

Retorna: Dados ou nulos se lidos falhou.

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)

Leia o pedido genérico de assinatura.

ReadTestRequestAsync

public virtual ValueTask<FixTestRequest?> ReadTestRequestAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadTestRequestAsync(cancellationToken)

Leia TestRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadTradingSessionStatusRequestAsync

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

result = fixServerSerializer.ReadTradingSessionStatusRequestAsync(cancellationToken)

Leia TradingSessionStatusRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadUserInfoAsync

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

result = fixServerSerializer.ReadUserInfoAsync(dateParser, cancellationToken)

Leia UserInfo message data.

dateParser

Data/hora analisador.

cancellationToken

Inscrição de cancelamento.

Retorna: Dados de informação do usuário ou nulos se lidos falhou.

ReadUserRequestAsync

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

result = fixServerSerializer.ReadUserRequestAsync(cancellationToken)

Leia UserRequest message data.

Retorna: Dados ou nulos se lidos falhou.

ReadUserRequestExAsync

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

result = fixServerSerializer.ReadUserRequestExAsync(cancellationToken)

Leia UserRequestEx message data.

Retorna: Dados ou nulos se lidos falhou.

WriteAsync

public virtual ValueTask WriteAsync(FixUserInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva informações de usuário.

WriteAsync

public virtual ValueTask WriteAsync(FixOrderMassCancelReport data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escrever o relatório de cancelamento em massa da ordem.

WriteAsync

public virtual ValueTask WriteAsync(FixOrderCancelReject data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escrever ordem cancelar rejeição.

WriteAsync

public virtual ValueTask WriteAsync(FixExecutionReport data, Func<IFixWriter, OrderCondition, CancellationToken, ValueTask> condition, bool convertToLatin, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, condition, convertToLatin, cancellationToken)

Escreva o relatório de execução.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscription data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva a subscrição.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionOnline data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva a subscrição online.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionFinished data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

A subscrição de escrita terminou.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escrever a resposta da subscrição.

WriteAsync

public virtual ValueTask WriteAsync(FixBoard data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva uma mensagem do conselho.

WriteAsync

public virtual ValueTask WriteAsync(FixTradingSessionStatus data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escrever status da sessão de negociação.

WriteAsync

public virtual ValueTask WriteAsync(FixReject data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva mensagem de rejeição.

WriteAsync

public virtual ValueTask WriteAsync(FixLogonResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva a resposta de logon.

WriteAsync

public virtual ValueTask WriteAsync(FixHeartbeat data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva a resposta do batimento cardíaco.

WriteAsync

public virtual ValueTask WriteAsync(FixSecurityLegsInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva informações sobre instrumentos financeiros.

WriteAsync

public virtual ValueTask WriteAsync(FixSecurityListResponseError data, bool convertToLatin, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, convertToLatin, cancellationToken)

Escrever a resposta da lista de instrumentos financeiros com erro.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataSnapshotFullRefresh data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva o instantâneo de dados do mercado de atualização completa.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataIncrementalRefresh data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva dados de mercado atualização incremental.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataRequestReject data, bool convertToLatin, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, convertToLatin, cancellationToken)

Rejeitar a solicitação de dados do mercado.

WriteAsync

public virtual ValueTask WriteAsync(FixNews data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva uma mensagem de notícias.

WriteAsync

public virtual ValueTask WriteAsync(FixDataTypeInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva informações do tipo de dados.

WriteAsync

public virtual ValueTask WriteAsync(FixRemoteFile data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Gravar ficheiro remoto.

WriteAsync

public virtual ValueTask WriteAsync(FixPositionReport data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva o relatório de posição.

WriteAsync

public virtual ValueTask WriteAsync(FixSecurityListResponse data, bool convertToLatin, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, convertToLatin, cancellationToken)

Retirar a resposta da lista de instrumentos financeiros.

WriteAsync

public virtual ValueTask WriteAsync(FixUserResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escreva a resposta do usuário.

WriteEntriesAsync

protected ValueTask WriteEntriesAsync(IFixWriter writer, ICollection<MDEntry> entries, CancellationToken cancellationToken)

result = fixServerSerializer.WriteEntriesAsync(writer, entries, cancellationToken)

Escreva entradas MD.

WriteFixMessageAsync

protected ValueTask WriteFixMessageAsync(string msgType, Func<IFixWriter, CancellationToken, ValueTask> handler, CancellationToken cancellationToken)

result = fixServerSerializer.WriteFixMessageAsync(msgType, handler, cancellationToken)

Escreva uma mensagem FIX com o tipo de mensagem especificado.

msgType

O tipo de mensagem FIX.

handler

O responsável pela gravação do corpo da mensagem.

cancellationToken

Inscrição de cancelamento.

WriteFixOrderConditionAsync

protected virtual ValueTask WriteFixOrderConditionAsync(IFixWriter writer, OrderCondition condition, CancellationToken cancellationToken)

result = fixServerSerializer.WriteFixOrderConditionAsync(writer, condition, cancellationToken)

Escreva condição de ordem FIX (para ordens de parada/algo).

WriteOrderConditionAsync

public virtual ValueTask WriteOrderConditionAsync(OrderCondition condition, CancellationToken cancellationToken)

result = fixServerSerializer.WriteOrderConditionAsync(condition, cancellationToken)

Escrever condição de ordem (para ordens de paragem/algo).