Freigeben über


OperationDataStream Schnittstelle

public interface OperationDataStream

Ein system.fabric.OperationDataStream Kapselt einen Datenstrom von OperationData Objekten, die zwischen dem primären Replikat und dem sekundären Replikat ausgetauscht werden. Objekte, die implementieren system.fabric.OperationDataStream , werden während des Kopiervorgangs verwendet. Sowohl die Kopierkontextmethode getCopyContext() , die vom sekundären Replikat an das primäre Replikat gesendet wird, als auch die Kopierzustandsmethode getCopyState(SequenceNumber upToSequenceNumber, OperationDataStream copyContext) implementieren die system.fabric.OperationDataStream Schnittstelle.

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
CompletableFuture<OperationData> getNextAsync(CancellationToken cancellationToken)

Ruft das nächste OperationData -Objekt von ab system.fabric.OperationDataStream.

Details zur Methode

getNextAsync

public CompletableFuture getNextAsync(CancellationToken cancellationToken)

Ruft das nächste OperationData -Objekt von ab system.fabric.OperationDataStream.

Parameter:

cancellationToken - Das CancellationToken Objekt, das vom Vorgang beobachtet wird. Sie kann verwendet werden, um eine Benachrichtigung zu senden, dass der Vorgang abgebrochen werden soll. Beachten Sie, dass der Abbruch eine Empfehlung ist und dass der Vorgang auch dann abgeschlossen werden kann, wenn er abgebrochen wird.

Gibt zurück:

java.util.concurrent.CompletableFuture vom Typ OperationData Die Zukunft schließt ausnahmsweise für FabricException Fabric-bezogene Fehler ab.

Gilt für: