Class CompletableToListenableFutureAdapter<T>
java.lang.Object
org.springframework.util.concurrent.CompletableToListenableFutureAdapter<T>
- Type Parameters:
T
- the result type returned by this Future'sget
method
- All Implemented Interfaces:
Future<T>
,ListenableFuture<T>
- Direct Known Subclasses:
MonoToListenableFutureAdapter
- Since:
- 4.2
- Author:
- Sebastien Deleuze, Juergen Hoeller
-
Constructor Summary
ConstructorDescriptionCompletableToListenableFutureAdapter
(CompletableFuture<T> completableFuture) Create a new adapter for the givenCompletableFuture
.CompletableToListenableFutureAdapter
(CompletionStage<T> completionStage) Create a new adapter for the givenCompletionStage
. -
Method Summary
Modifier and TypeMethodDescriptionvoid
addCallback
(ListenableFutureCallback<? super T> callback) Register the givenListenableFutureCallback
.void
addCallback
(SuccessCallback<? super T> successCallback, FailureCallback failureCallback) Java 8 lambda-friendly alternative with success and failure callbacks.boolean
cancel
(boolean mayInterruptIfRunning) Expose thisListenableFuture
as a JDKCompletableFuture
.get()
boolean
boolean
isDone()
-
Constructor Details
-
CompletableToListenableFutureAdapter
Create a new adapter for the givenCompletionStage
.- Since:
- 4.3.7
-
CompletableToListenableFutureAdapter
Create a new adapter for the givenCompletableFuture
.
-
-
Method Details
-
addCallback
Description copied from interface:ListenableFuture
Register the givenListenableFutureCallback
.- Specified by:
addCallback
in interfaceListenableFuture<T>
- Parameters:
callback
- the callback to register
-
addCallback
public void addCallback(SuccessCallback<? super T> successCallback, FailureCallback failureCallback) Description copied from interface:ListenableFuture
Java 8 lambda-friendly alternative with success and failure callbacks.- Specified by:
addCallback
in interfaceListenableFuture<T>
- Parameters:
successCallback
- the success callbackfailureCallback
- the failure callback
-
completable
Description copied from interface:ListenableFuture
Expose thisListenableFuture
as a JDKCompletableFuture
.- Specified by:
completable
in interfaceListenableFuture<T>
-
cancel
public boolean cancel(boolean mayInterruptIfRunning) -
isCancelled
public boolean isCancelled()- Specified by:
isCancelled
in interfaceFuture<T>
-
isDone
public boolean isDone() -
get
- Specified by:
get
in interfaceFuture<T>
- Throws:
InterruptedException
ExecutionException
-
get
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
get
in interfaceFuture<T>
- Throws:
InterruptedException
ExecutionException
TimeoutException
-