OperationStream Interface

Package:

system.fabric

public interface OperationStream

Represents a stream of replication or copy operations that are sent from the Primary to the Secondary replica.

Remarks: The streams returned from getCopyStream() and getReplicationStream() are objects that implement system.fabric.OperationStream.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Operation>	getOperationAsync(CancellationToken cancellationToken) Gets the next object that implements Operation from the underlying system.fabric.OperationStream.

Method Details

getOperationAsync

public CompletableFuture getOperationAsync(CancellationToken cancellationToken)

Gets the next object that implements Operation from the underlying system.fabric.OperationStream.

Parameters:

cancellationToken - The CancellationToken object that the operation is observing. It can be used to send a notification that the operation should be canceled. Note that cancellation is advisory and that the operation might still be completed even if it is canceled.

Returns:

Returns java.util.concurrent.CompletableFuture of type Operation. The future completes exceptionally with FabricException for fabric related failures.