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)

Inicia una nueva instancia de la FixServerSerializer.

reader

El lector FIX para analizar mensajes entrantes.

writer

El escritor de la FIX para escribir mensajes salientes.

bodyWriter

El escritor de la FIX para el cuerpo del mensaje.

version

La versión de protocolo FIX.

senderCompId

El ID de compendio del remitente.

targetCompId

El identificador de comp.

dateParser

El parser de citas.

dateTimeParser

El parser de fecha/hora.

timeParser

El parser de tiempo.

getNextId

Función para obtener el siguiente ID de secuencia de mensajes.

Reader

public IFixReader Reader { get; }

value = fixServerSerializer.Reader

El lector FIX para analizar mensajes entrantes.

Writer

public IFixWriter Writer { get; }

value = fixServerSerializer.Writer

El escritor de la FIX para escribir mensajes salientes.

Convert

protected static string Convert(string value, bool convertToLatin)

result = FixServerSerializer.Convert(value, convertToLatin)

Convertir cadena en latín si es necesario.

ReadBoardLookupAsync

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

result = fixServerSerializer.ReadBoardLookupAsync(cancellationToken)

Lea BoardLookup@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

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)

Lea el mensaje de suscripción BoardLookup.

session

Sesión de cliente.

createTransactionId

Creador de identificación de transacciones.

getTransactionId

Trae el identificador de transacciones.

cancellationToken

Cancelación token.

Devuelve: Mensajes de búsqueda de la Junta con ID de solicitud.

ReadBoardUpdateAsync

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

result = fixServerSerializer.ReadBoardUpdateAsync(cancellationToken)

Lea BoardUpdate@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

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)

Lee el mensaje del comando.

ReadDataTypeLookupAsync

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

result = fixServerSerializer.ReadDataTypeLookupAsync(cancellationToken)

Lea DataTypeLookup@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadHeartbeatAsync

public virtual ValueTask<bool> ReadHeartbeatAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHeartbeatAsync(cancellationToken)

Lea Mensaje de latido cardíaco (consume el mensaje, devuelve el éxito).

ReadHistoryEndAsync

public virtual ValueTask<bool> ReadHistoryEndAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHistoryEndAsync(cancellationToken)

Lea HistoryEnd Mensaje (consumes de mensaje, devuelve el éxito).

ReadHistoryStartAsync

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

result = fixServerSerializer.ReadHistoryStartAsync(cancellationToken)

Lea HistoryStart@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadLogoutAsync

public virtual ValueTask<bool> ReadLogoutAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadLogoutAsync(cancellationToken)

Lea Mensaje de registro (consume el mensaje, devuelve el éxito).

ReadMarketDataRequestAsync

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

result = fixServerSerializer.ReadMarketDataRequestAsync(dateParser, cancellationToken)

Lea MarketDataRequest@s datos de mensajes.

dateParser

Fecha/hora de parser para campos de fecha.

cancellationToken

Cancelación token.

Devuelve: Enumerable as?ncrono de solicitudes de datos 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)

Lea NewOrderSingle@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadNewsAsync

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

result = fixServerSerializer.ReadNewsAsync(dateParser, cancellationToken)

Lea los datos del mensaje de noticias.

dateParser

Fecha/hora.

cancellationToken

Cancelación token.

Devuelve: Mensajes de noticias.

ReadOrderCancelReplaceRequestAsync

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

result = fixServerSerializer.ReadOrderCancelReplaceRequestAsync(cancellationToken)

Lea OrderCancelReplaceRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadOrderCancelRequestAsync

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

result = fixServerSerializer.ReadOrderCancelRequestAsync(cancellationToken)

Lea OrderCancelRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadOrderConditionAsync

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

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

Lea la condición de pedido de las etiquetas FIX.

ReadOrderMassCancelRequestAsync

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

result = fixServerSerializer.ReadOrderMassCancelRequestAsync(cancellationToken)

Lea OrderMassCancelRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadOrderMassStatusRequestAsync

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

result = fixServerSerializer.ReadOrderMassStatusRequestAsync(cancellationToken)

Lea OrderMassStatusRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadOrderStatusRequestAsync

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

result = fixServerSerializer.ReadOrderStatusRequestAsync(cancellationToken)

Lea OrderStatusRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadRemoveAsync

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

result = fixServerSerializer.ReadRemoveAsync(cancellationToken)

Lea Quitar datos de mensaje.

Devuelve: Datos o nulos si no se lee.

ReadRequestForPositionsAsync

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

result = fixServerSerializer.ReadRequestForPositionsAsync(cancellationToken)

Lea RequestForPositions@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadResendRequestAsync

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

result = fixServerSerializer.ReadResendRequestAsync(cancellationToken)

Lea ResendRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadSecurityLegsRequestAsync

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

result = fixServerSerializer.ReadSecurityLegsRequestAsync(cancellationToken)

Lea SecurityLegsRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadSecurityListDeleteAsync

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

result = fixServerSerializer.ReadSecurityListDeleteAsync(cancellationToken)

Lea SecurityListDelete@s datos de mensajes.

Devuelve: Arregle de los IDs de instrumentos financieros para eliminar, o null si no se lee.

ReadSecurityListRequestAsync

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

result = fixServerSerializer.ReadSecurityListRequestAsync(cancellationToken)

Lea SecurityListRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadSecurityListUploadAsync

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

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

Lea los mensajes SecurityListUpload.

dateParser

Fecha/hora.

yearMonthParser

Un parser de año.

logError

Error de registro de la acción.

cancellationToken

Cancelación token.

Devuelve: mensajes de instrumentos financieros.

ReadSecurityMappingAsync

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

result = fixServerSerializer.ReadSecurityMappingAsync(cancellationToken)

Lea SecurityMapping@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadSecurityStatusRequestAsync

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

result = fixServerSerializer.ReadSecurityStatusRequestAsync(cancellationToken)

Lea SecurityStatusRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadSequenceResetAsync

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

result = fixServerSerializer.ReadSequenceResetAsync(cancellationToken)

Lea SequenceReset@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

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)

Lea la solicitud de suscripción genérica.

ReadTestRequestAsync

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

result = fixServerSerializer.ReadTestRequestAsync(cancellationToken)

Lea TestRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadTradingSessionStatusRequestAsync

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

result = fixServerSerializer.ReadTradingSessionStatusRequestAsync(cancellationToken)

Lea TradingSessionStatusRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadUserInfoAsync

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

result = fixServerSerializer.ReadUserInfoAsync(dateParser, cancellationToken)

Lea UserInfo@s datos de mensajes.

dateParser

Fecha/hora.

cancellationToken

Cancelación token.

Devuelve: Datos de información de usuario o null si lee falló.

ReadUserRequestAsync

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

result = fixServerSerializer.ReadUserRequestAsync(cancellationToken)

Lea UserRequest@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

ReadUserRequestExAsync

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

result = fixServerSerializer.ReadUserRequestExAsync(cancellationToken)

Lea UserRequestEx@s datos de mensajes.

Devuelve: Datos o nulos si no se lee.

WriteAsync

public virtual ValueTask WriteAsync(FixUserInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe información de usuario.

WriteAsync

public virtual ValueTask WriteAsync(FixOrderMassCancelReport data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe el informe de cancelación masiva de pedidos.

WriteAsync

public virtual ValueTask WriteAsync(FixOrderCancelReject data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escriba orden de cancelación de rechazo.

WriteAsync

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

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

Escribe informe de ejecución.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscription data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe tu suscripción.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionOnline data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe tu suscripción en línea.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionFinished data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe tu suscripción terminada.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe respuesta de suscripción.

WriteAsync

public virtual ValueTask WriteAsync(FixBoard data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe un mensaje de la junta.

WriteAsync

public virtual ValueTask WriteAsync(FixTradingSessionStatus data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escriba el estado de la sesión de comercio.

WriteAsync

public virtual ValueTask WriteAsync(FixReject data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe mensaje de rechazo.

WriteAsync

public virtual ValueTask WriteAsync(FixLogonResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe respuesta de logon.

WriteAsync

public virtual ValueTask WriteAsync(FixHeartbeat data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe respuesta de latidos cardíacos.

WriteAsync

public virtual ValueTask WriteAsync(FixSecurityLegsInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe información sobre las piernas de instrumentos financieros.

WriteAsync

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

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

Escriba respuesta de lista de instrumentos financieros con error.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataSnapshotFullRefresh data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe datos de mercado instantánea de actualización completa.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataIncrementalRefresh data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe datos de mercado refrescación incremental.

WriteAsync

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

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

Escriba la solicitud de datos del mercado rechazada.

WriteAsync

public virtual ValueTask WriteAsync(FixNews data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe un mensaje de noticias.

WriteAsync

public virtual ValueTask WriteAsync(FixDataTypeInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escriba información del tipo de datos.

WriteAsync

public virtual ValueTask WriteAsync(FixRemoteFile data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe un archivo remoto.

WriteAsync

public virtual ValueTask WriteAsync(FixPositionReport data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe informe de posición.

WriteAsync

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

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

Escribe respuesta de lista de instrumentos financieros.

WriteAsync

public virtual ValueTask WriteAsync(FixUserResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Escribe respuesta del usuario.

WriteEntriesAsync

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

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

Escribe entradas de MD.

WriteFixMessageAsync

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

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

Escriba un mensaje FIX con el tipo de mensaje especificado.

msgType

El tipo de mensaje FIX.

handler

El manipulador para escribir el cuerpo del mensaje.

cancellationToken

Cancelación token.

WriteFixOrderConditionAsync

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

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

Escriba la condición de orden FIX (para órdenes de parada/algo).

WriteOrderConditionAsync

public virtual ValueTask WriteOrderConditionAsync(OrderCondition condition, CancellationToken cancellationToken)

result = fixServerSerializer.WriteOrderConditionAsync(condition, cancellationToken)

Escribir la condición de pedido (para órdenes de parada/algo).