com.oracle.bmc.waiter

Class GenericWaiter

java.lang.Object

com.oracle.bmc.waiter.GenericWaiter

public class GenericWaiter
extends Object

Provides a basic waiter that will periodically poll for an update until a desired condition is met.

Constructor Summary

Constructors

Constructor and Description
GenericWaiter(WaiterConfiguration waiterConfiguration)

Method Summary

Modifier and Type	Method and Description
<REQUEST,RESPONSE> Optional<RESPONSE>	execute(Supplier<REQUEST> requestSupplier, Function<REQUEST,RESPONSE> functionCall, Predicate<RESPONSE> terminationPredicate) Blocks until a specific condition is met.
<T> CompletionStage<Optional<T>>	executeAsync(WaiterScheduler runner, Supplier<CompletionStage<T>> downstream, Predicate<T> terminationPredicate)
WaiterConfiguration	getWaiterConfiguration()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GenericWaiter

@ConstructorProperties(value="waiterConfiguration")
public GenericWaiter(WaiterConfiguration waiterConfiguration)

Method Detail

execute

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

Blocks until a specific condition is met.

Type Parameters:

REQUEST - Request object class

RESPONSE - Response object class

Parameters:

requestSupplier - Supplier that provides a new request instance to fetch the current state.

functionCall - Function that will be invoked to fetch the current state. It will be provided the request instance given by the requestSupplier.

terminationPredicate - The termination predicate that will inspect the current state (returned response instance) to determine if it is done waiting.

Returns:

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

getWaiterConfiguration

public WaiterConfiguration getWaiterConfiguration()

executeAsync

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