public interface CompositeFuture extends Future<CompositeFuture>
futures
, it is useful when several futures
needs to be coordinated.
The handlers set for the coordinated futures are overridden by the handler of the composite future.Modifier and Type | Method and Description |
---|---|
static <T1,T2> CompositeFuture |
all(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2,T3> CompositeFuture |
all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
all(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
all(Future, Future) but with 6 futures. |
static CompositeFuture |
all(List<Future> futures)
Like
all(Future, Future) but with a list of futures. |
static <T1,T2> CompositeFuture |
any(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when any futures is succeeded, failed when all futures are failed.
|
static <T1,T2,T3> CompositeFuture |
any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
any(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
any(Future, Future) but with 6 futures. |
static CompositeFuture |
any(List<Future> futures)
Like
any(Future, Future) but with a list of futures. |
Throwable |
cause(int index)
Returns a cause of a wrapped future
|
default List<Throwable> |
causes() |
boolean |
failed(int index)
Returns true if a wrapped future is failed
|
boolean |
isComplete(int index)
Returns true if a wrapped future is completed
|
static <T1,T2> CompositeFuture |
join(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2,T3> CompositeFuture |
join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
join(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
join(Future, Future) but with 6 futures. |
static CompositeFuture |
join(List<Future> futures)
Like
join(Future, Future) but with a list of futures. |
default <T> List<T> |
list() |
CompositeFuture |
onComplete(Handler<AsyncResult<CompositeFuture>> handler)
Add a handler to be notified of the result.
|
default CompositeFuture |
onFailure(Handler<Throwable> handler)
Add a handler to be notified of the failed result.
|
default CompositeFuture |
onSuccess(Handler<CompositeFuture> handler)
Add a handler to be notified of the succeeded result.
|
<T> T |
resultAt(int index)
Returns the result of a wrapped future
|
int |
size() |
boolean |
succeeded(int index)
Returns true if a wrapped future is succeeded
|
cause, compose, compose, eventually, failed, failedFuture, failedFuture, flatMap, fromCompletionStage, fromCompletionStage, future, isComplete, map, map, mapEmpty, otherwise, otherwise, otherwiseEmpty, recover, result, succeeded, succeededFuture, succeededFuture, toCompletionStage, transform
static <T1,T2> CompositeFuture all(Future<T1> f1, Future<T2> f2)
f1
or f2
fails.f1
- futuref2
- futurestatic <T1,T2,T3> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3)
all(Future, Future)
but with 3 futures.static <T1,T2,T3,T4> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4)
all(Future, Future)
but with 4 futures.static <T1,T2,T3,T4,T5> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5)
all(Future, Future)
but with 5 futures.static <T1,T2,T3,T4,T5,T6> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5, Future<T6> f6)
all(Future, Future)
but with 6 futures.static CompositeFuture all(List<Future> futures)
all(Future, Future)
but with a list of futures.When the list is empty, the returned future will be already completed.
static <T1,T2> CompositeFuture any(Future<T1> f1, Future<T2> f2)
f1
or f2
succeeds.f1
- futuref2
- futurestatic <T1,T2,T3> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3)
any(Future, Future)
but with 3 futures.static <T1,T2,T3,T4> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4)
any(Future, Future)
but with 4 futures.static <T1,T2,T3,T4,T5> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5)
any(Future, Future)
but with 5 futures.static <T1,T2,T3,T4,T5,T6> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5, Future<T6> f6)
any(Future, Future)
but with 6 futures.static CompositeFuture any(List<Future> futures)
any(Future, Future)
but with a list of futures.When the list is empty, the returned future will be already completed.
static <T1,T2> CompositeFuture join(Future<T1> f1, Future<T2> f2)
f1
or f2
fails.f1
- futuref2
- futurestatic <T1,T2,T3> CompositeFuture join(Future<T1> f1, Future<T2> f2, Future<T3> f3)
join(Future, Future)
but with 3 futures.static <T1,T2,T3,T4> CompositeFuture join(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4)
join(Future, Future)
but with 4 futures.static <T1,T2,T3,T4,T5> CompositeFuture join(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5)
join(Future, Future)
but with 5 futures.static <T1,T2,T3,T4,T5,T6> CompositeFuture join(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5, Future<T6> f6)
join(Future, Future)
but with 6 futures.static CompositeFuture join(List<Future> futures)
join(Future, Future)
but with a list of futures.When the list is empty, the returned future will be already completed.
CompositeFuture onComplete(Handler<AsyncResult<CompositeFuture>> handler)
Future
onComplete
in interface Future<CompositeFuture>
handler
- the handler that will be called with the resultdefault CompositeFuture onSuccess(Handler<CompositeFuture> handler)
Future
onSuccess
in interface Future<CompositeFuture>
handler
- the handler that will be called with the succeeded resultdefault CompositeFuture onFailure(Handler<Throwable> handler)
Future
onFailure
in interface Future<CompositeFuture>
handler
- the handler that will be called with the failed resultThrowable cause(int index)
index
- the wrapped future indexboolean succeeded(int index)
index
- the wrapped future indexboolean failed(int index)
index
- the wrapped future indexboolean isComplete(int index)
index
- the wrapped future index<T> T resultAt(int index)
index
- the wrapped future indexint size()
default <T> List<T> list()
Copyright © 2021 Eclipse. All rights reserved.