Modifier and Type	Class and Description
private static class	GenericWaiter.CancellableCompletableFuture<T>

Modifier and Type	Field and Description
private static final Logger	LOG
private final WaiterConfiguration	waiterConfiguration

Access	Constructor and Description
public	GenericWaiter(final WaiterConfiguration waiterConfiguration)

Method Summary

Modifier and Type	Method and Description
public < Request object class REQUEST, Response object class RESPONSE> Optional<RESPONSE>	Returns: The last response object that was received and was accepted by the termination predicate, or empty if the waiter reached the max timeout. execute(Supplier<REQUEST> Supplier that provides a new request instance to fetch the current state. requestSupplier, Function<REQUEST, RESPONSE> Function that will be invoked to fetch the current state. It will be provided the request instance given by the requestSupplier. functionCall, Predicate<RESPONSE> The termination predicate that will inspect the current state (returned response instance) to determine if it is done waiting. terminationPredicate) Blocks until a specific condition is met.
public <T> CompletionStage<Optional<T>>	executeAsync(WaiterScheduler runner, Supplier<CompletionStage<T>> downstream, Predicate<T> terminationPredicate)
private <T> CompletionStage<Optional<T>>	executeAsync(WaiterScheduler runner, Supplier<CompletionStage<T>> upstream, Predicate<T> terminationPredicate, WaiterConfiguration.WaitContext context)
private static <T> CompletionStage<T>	failedFuture(Throwable t)
public WaiterConfiguration	getWaiterConfiguration()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

LOG	back to summary
private static final Logger LOG

waiterConfiguration	back to summary
private final WaiterConfiguration waiterConfiguration

GenericWaiter	back to summary
public GenericWaiter(final WaiterConfiguration waiterConfiguration) Annotations @java.beans.ConstructorProperties

Method Detail

execute	back to summary
public <REQUEST, RESPONSE> Optional<RESPONSE> execute(Supplier<REQUEST> requestSupplier, Function<REQUEST, RESPONSE> functionCall, Predicate<RESPONSE> terminationPredicate) Blocks until a specific condition is met. Parameters <REQUEST> Request object class <RESPONSE> Response object class requestSupplier:Supplier<REQUEST> Supplier that provides a new request instance to fetch the current state. functionCall:Function<REQUEST, RESPONSE> Function that will be invoked to fetch the current state. It will be provided the request instance given by the requestSupplier. terminationPredicate:Predicate<RESPONSE> The termination predicate that will inspect the current state (returned response instance) to determine if it is done waiting. Returns:Optional<RESPONSE> The last response object that was received and was accepted by the termination predicate, or empty if the waiter reached the max timeout.

execute

back to summary

public <REQUEST, RESPONSE> Optional<RESPONSE> execute(Supplier<REQUEST> requestSupplier, Function<REQUEST, RESPONSE> functionCall, Predicate<RESPONSE> terminationPredicate)

Blocks until a specific condition is met.

Parameters

<REQUEST>: Request object class
<RESPONSE>: Response object class
requestSupplier:Supplier<REQUEST>: Supplier that provides a new request instance to fetch the current state.
functionCall:Function<REQUEST, RESPONSE>: Function that will be invoked to fetch the current state. It will be provided the request instance given by the requestSupplier.
terminationPredicate:Predicate<RESPONSE>: The termination predicate that will inspect the current state (returned response instance) to determine if it is done waiting.

Returns:Optional<RESPONSE>

The last response object that was received and was accepted by the termination predicate, or empty if the waiter reached the max timeout.

executeAsync	back to summary
public <T> CompletionStage<Optional<T>> executeAsync(WaiterScheduler runner, Supplier<CompletionStage<T>> downstream, Predicate<T> terminationPredicate)

executeAsync	back to summary
private <T> CompletionStage<Optional<T>> executeAsync(WaiterScheduler runner, Supplier<CompletionStage<T>> upstream, Predicate<T> terminationPredicate, WaiterConfiguration.WaitContext context)

failedFuture	back to summary
private static <T> CompletionStage<T> failedFuture(Throwable t)

getWaiterConfiguration	back to summary
public WaiterConfiguration getWaiterConfiguration()

com.oracle.bmc.waiter back to summary

private Class GenericWaiter.CancellableCompletableFuture<T>

Class Inheritance

extends CompletableFuture<T>

java.lang.Object
java.util.concurrent.CompletableFuture
com.oracle.bmc.waiter.GenericWaiter.CancellableCompletableFuture

Field Summary

Modifier and Type	Field and Description
pack-priv volatile Future<?>	upstreamFuture

Constructor Summary

Access	Constructor and Description
private	CancellableCompletableFuture()

Method Summary

Modifier and Type	Method and Description
public boolean	cancel(boolean this value has no effect in this implementation because interrupts are not used to control processing. mayInterruptIfRunning) Overrides java.util.concurrent.CompletableFuture.cancel. Implements java.util.concurrent.Future.cancel. If not already completed, completes this CompletableFuture with a `CancellationException`.

Inherited from java.util.concurrent.CompletableFuture:: acceptEither acceptEitherAsync acceptEitherAsync allOf anyOf applyToEither applyToEitherAsync applyToEitherAsync complete completeAsync completeAsync completedFuture completedStage completeExceptionally completeOnTimeout copy defaultExecutor delayedExecutor delayedExecutor exceptionally exceptionallyAsync exceptionallyAsync exceptionallyCompose exceptionallyComposeAsync exceptionallyComposeAsync exceptionNow failedFuture failedStage get get getNow getNumberOfDependents handle handleAsync handleAsync isCancelled isCompletedExceptionally isDone join minimalCompletionStage newIncompleteFuture obtrudeException obtrudeValue orTimeout resultNow runAfterBoth runAfterBothAsync runAfterBothAsync runAfterEither runAfterEitherAsync runAfterEitherAsync runAsync runAsync state supplyAsync supplyAsync thenAccept thenAcceptAsync thenAcceptAsync thenAcceptBoth thenAcceptBothAsync thenAcceptBothAsync thenApply thenApplyAsync thenApplyAsync thenCombine thenCombineAsync thenCombineAsync thenCompose thenComposeAsync thenComposeAsync thenRun thenRunAsync thenRunAsync toCompletableFuture toString whenComplete whenCompleteAsync whenCompleteAsync

Field Detail

upstreamFuture	back to summary
pack-priv volatile Future<?> upstreamFuture

Constructor Detail

CancellableCompletableFuture	back to summary
private CancellableCompletableFuture()

Method Detail

cancel back to summary

cancel	back to summary
public boolean cancel(boolean mayInterruptIfRunning) Overrides java.util.concurrent.CompletableFuture.cancel. Implements java.util.concurrent.Future.cancel. Doc from java.util.concurrent.CompletableFuture.cancel. If not already completed, completes this CompletableFuture with a `CancellationException`. Dependent CompletableFutures that have not already completed will also complete exceptionally, with a `CompletionException` caused by this `CancellationException`. Parameters mayInterruptIfRunning:boolean this value has no effect in this implementation because interrupts are not used to control processing. Returns:boolean `true` if this task is now cancelled Annotations @Override

public boolean cancel(boolean mayInterruptIfRunning)

Overrides java.util.concurrent.CompletableFuture.cancel.

Implements java.util.concurrent.Future.cancel.

Doc from java.util.concurrent.CompletableFuture.cancel.

If not already completed, completes this CompletableFuture with a CancellationException. Dependent CompletableFutures that have not already completed will also complete exceptionally, with a CompletionException caused by this CancellationException.

Parameters

mayInterruptIfRunning:boolean: this value has no effect in this implementation because interrupts are not used to control processing.

Returns:boolean

true if this task is now cancelled

Annotations

@Override

public Class GenericWaiter

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class GenericWaiter.CancellableCompletableFuture<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail