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)

Initialisiert eine neue Instanz von FixServerSerializer.

reader

Der FIX-Reader zum Parsen eingehender Nachrichten.

writer

Der FIX-Schriftsteller zum Schreiben ausgehender Nachrichten.

bodyWriter

Der FIX-Schriftsteller für Message Body.

version

Die FIX-Protokollversion.

senderCompId

Die Absender-Comp-ID.

targetCompId

Die Target Comp ID.

dateParser

Der Datums-Parser.

dateTimeParser

Datum/Uhrzeit-Parser.

timeParser

Der Zeitparser.

getNextId

Funktion, um die nächste Nachrichtensequenz-ID zu erhalten.

Reader

public IFixReader Reader { get; }

value = fixServerSerializer.Reader

Der FIX-Reader zum Parsen eingehender Nachrichten.

Writer

public IFixWriter Writer { get; }

value = fixServerSerializer.Writer

Der FIX-Schriftsteller zum Schreiben ausgehender Nachrichten.

Convert

protected static string Convert(string value, bool convertToLatin)

result = FixServerSerializer.Convert(value, convertToLatin)

Konvertieren Sie String in Latein, wenn nötig.

ReadBoardLookupAsync

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

result = fixServerSerializer.ReadBoardLookupAsync(cancellationToken)

Lesen Sie BoardLookup Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

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)

Lesen Sie BoardLookup Abonnementnachricht.

session

Client Session.

createTransactionId

Transaktions-ID-Ersteller.

getTransactionId

Transaktions-ID-Getter.

cancellationToken

Löschungszeichen.

Rückgabe: Board-Lookup-Nachrichten mit Request-IDs.

ReadBoardUpdateAsync

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

result = fixServerSerializer.ReadBoardUpdateAsync(cancellationToken)

Lesen Sie BoardUpdate Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

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)

Lesen Sie die Befehlsnachricht.

ReadDataTypeLookupAsync

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

result = fixServerSerializer.ReadDataTypeLookupAsync(cancellationToken)

Lesen Sie DataTypeLookup Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadHeartbeatAsync

public virtual ValueTask<bool> ReadHeartbeatAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHeartbeatAsync(cancellationToken)

Lesen Sie Heartbeat Nachricht (verbraucht Nachricht, kehrt Erfolg).

ReadHistoryEndAsync

public virtual ValueTask<bool> ReadHistoryEndAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadHistoryEndAsync(cancellationToken)

Lesen Sie HistoryEnd @ Nachricht (verbraucht Nachricht, gibt Erfolg zurück).

ReadHistoryStartAsync

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

result = fixServerSerializer.ReadHistoryStartAsync(cancellationToken)

Lesen Sie HistoryStart Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadLogoutAsync

public virtual ValueTask<bool> ReadLogoutAsync(CancellationToken cancellationToken)

result = fixServerSerializer.ReadLogoutAsync(cancellationToken)

Lesen Sie die Logout-Nachricht (verbraucht die Nachricht, gibt den Erfolg zurück).

ReadMarketDataRequestAsync

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

result = fixServerSerializer.ReadMarketDataRequestAsync(dateParser, cancellationToken)

Lesen Sie MarketDataRequest Nachrichtendaten.

dateParser

Datum/Uhrzeit-Parser für Datumsfelder.

cancellationToken

Löschungszeichen.

Rückgabe: Async enumerable von Marktdatenanforderungen.

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)

Lesen Sie NewOrderSingle Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadNewsAsync

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

result = fixServerSerializer.ReadNewsAsync(dateParser, cancellationToken)

Lesen Sie Nachrichtennachrichtendaten.

dateParser

Datum/Uhrzeit-Parser.

cancellationToken

Löschungszeichen.

Rückgabe: Nachrichten.

ReadOrderCancelReplaceRequestAsync

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

result = fixServerSerializer.ReadOrderCancelReplaceRequestAsync(cancellationToken)

Lesen Sie OrderCancelReplaceRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadOrderCancelRequestAsync

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

result = fixServerSerializer.ReadOrderCancelRequestAsync(cancellationToken)

Lesen Sie OrderCancelRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadOrderConditionAsync

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

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

Lesen Sie die Bestellbedingung von FIX-Tags.

ReadOrderMassCancelRequestAsync

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

result = fixServerSerializer.ReadOrderMassCancelRequestAsync(cancellationToken)

Lesen Sie OrderMassCancelRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadOrderMassStatusRequestAsync

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

result = fixServerSerializer.ReadOrderMassStatusRequestAsync(cancellationToken)

Lesen Sie OrderMassStatusRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadOrderStatusRequestAsync

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

result = fixServerSerializer.ReadOrderStatusRequestAsync(cancellationToken)

Lesen Sie OrderStatusRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadRemoveAsync

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

result = fixServerSerializer.ReadRemoveAsync(cancellationToken)

Lesen Sie Nachrichtendaten entfernen.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadRequestForPositionsAsync

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

result = fixServerSerializer.ReadRequestForPositionsAsync(cancellationToken)

Lesen Sie RequestForPositions Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadResendRequestAsync

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

result = fixServerSerializer.ReadResendRequestAsync(cancellationToken)

Lesen Sie ResendRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadSecurityLegsRequestAsync

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

result = fixServerSerializer.ReadSecurityLegsRequestAsync(cancellationToken)

Lesen Sie SecurityLegsRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadSecurityListDeleteAsync

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

result = fixServerSerializer.ReadSecurityListDeleteAsync(cancellationToken)

Lesen Sie SecurityListDelete Nachrichtendaten.

Rückgabe: Array von Finanzinstrument-IDs zu löschen, oder null, wenn gelesen fehlgeschlagen.

ReadSecurityListRequestAsync

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

result = fixServerSerializer.ReadSecurityListRequestAsync(cancellationToken)

Lesen Sie SecurityListRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadSecurityListUploadAsync

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

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

Lesen Sie SecurityListUpload Nachrichten.

dateParser

Datum/Uhrzeit-Parser.

yearMonthParser

Jahr-Monats-Parser.

logError

Fehlerprotokollierungsaktion.

cancellationToken

Löschungszeichen.

Rückgabe: Finanzinstrumentmeldungen.

ReadSecurityMappingAsync

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

result = fixServerSerializer.ReadSecurityMappingAsync(cancellationToken)

Lesen Sie SecurityMapping Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadSecurityStatusRequestAsync

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

result = fixServerSerializer.ReadSecurityStatusRequestAsync(cancellationToken)

Lesen Sie SecurityStatusRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadSequenceResetAsync

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

result = fixServerSerializer.ReadSequenceResetAsync(cancellationToken)

Lesen Sie SequenceReset Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

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)

Lesen Sie generische Abonnementanfrage.

ReadTestRequestAsync

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

result = fixServerSerializer.ReadTestRequestAsync(cancellationToken)

Lesen Sie TestRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadTradingSessionStatusRequestAsync

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

result = fixServerSerializer.ReadTradingSessionStatusRequestAsync(cancellationToken)

Lesen Sie TradingSessionStatusRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadUserInfoAsync

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

result = fixServerSerializer.ReadUserInfoAsync(dateParser, cancellationToken)

Lesen Sie UserInfo Nachrichtendaten.

dateParser

Datum/Uhrzeit-Parser.

cancellationToken

Löschungszeichen.

Rückgabe: Benutzerinformationen oder null, wenn read fehlgeschlagen ist.

ReadUserRequestAsync

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

result = fixServerSerializer.ReadUserRequestAsync(cancellationToken)

Lesen Sie UserRequest Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

ReadUserRequestExAsync

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

result = fixServerSerializer.ReadUserRequestExAsync(cancellationToken)

Lesen Sie UserRequestEx Nachrichtendaten.

Rückgabe: Daten oder null, wenn gelesen fehlgeschlagen ist.

WriteAsync

public virtual ValueTask WriteAsync(FixUserInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Benutzerinformationen.

WriteAsync

public virtual ValueTask WriteAsync(FixOrderMassCancelReport data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie den Massenstornierungsbericht.

WriteAsync

public virtual ValueTask WriteAsync(FixOrderCancelReject data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibauftrag annullieren ablehnen.

WriteAsync

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

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

Schreiben Sie einen Ausführungsbericht.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscription data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibe ein Abonnement.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionOnline data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie ein Abonnement online.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionFinished data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibe das Abonnement fertig.

WriteAsync

public virtual ValueTask WriteAsync(FixSubscriptionResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie die Antwort auf das Abonnement.

WriteAsync

public virtual ValueTask WriteAsync(FixBoard data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibe Board Message.

WriteAsync

public virtual ValueTask WriteAsync(FixTradingSessionStatus data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie den Status der Handelssitzung.

WriteAsync

public virtual ValueTask WriteAsync(FixReject data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibe eine ablehnende Nachricht.

WriteAsync

public virtual ValueTask WriteAsync(FixLogonResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibe die Antwort an.

WriteAsync

public virtual ValueTask WriteAsync(FixHeartbeat data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Heartbeat Response.

WriteAsync

public virtual ValueTask WriteAsync(FixSecurityLegsInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Informationen zu Finanzinstrumenten.

WriteAsync

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

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

Schreiben Sie die Antwort auf die Liste der Finanzinstrumente mit Fehler.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataSnapshotFullRefresh data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Marktdaten Snapshot voller Refresh.

WriteAsync

public virtual ValueTask WriteAsync(FixMarketDataIncrementalRefresh data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Marktdaten inkrementelle Aktualisierung.

WriteAsync

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

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

Schreiben Marktdaten Anfrage ablehnen.

WriteAsync

public virtual ValueTask WriteAsync(FixNews data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreibe Nachrichtennachrichten.

WriteAsync

public virtual ValueTask WriteAsync(FixDataTypeInfo data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Datentypinformationen.

WriteAsync

public virtual ValueTask WriteAsync(FixRemoteFile data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Remote-Datei.

WriteAsync

public virtual ValueTask WriteAsync(FixPositionReport data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie Positionsbericht.

WriteAsync

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

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

Schreiben Sie die Antwort auf die Liste der Finanzinstrumente.

WriteAsync

public virtual ValueTask WriteAsync(FixUserResponse data, CancellationToken cancellationToken)

result = fixServerSerializer.WriteAsync(data, cancellationToken)

Schreiben Sie die User Response.

WriteEntriesAsync

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

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

Schreiben Sie MD-Einträge.

WriteFixMessageAsync

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

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

Schreiben Sie eine FIX-Nachricht mit dem angegebenen Nachrichtentyp.

msgType

Der FIX-Nachrichtentyp.

handler

Der Handler, um Message Body zu schreiben.

cancellationToken

Löschungszeichen.

WriteFixOrderConditionAsync

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

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

Schreibe die FIX-Orderbedingung (für Stop- / Algo-Orders).

WriteOrderConditionAsync

public virtual ValueTask WriteOrderConditionAsync(OrderCondition condition, CancellationToken cancellationToken)

result = fixServerSerializer.WriteOrderConditionAsync(condition, cancellationToken)

Schreibe die Auftragsbedingung (für Stop/Algo-Aufträge).