public class CompositeFuture extends Future<CompositeFuture>
Constructor and Description |
---|
CompositeFuture(CompositeFuture delegate) |
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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with 3 futures. |
static <T1,T2,T3,T4> |
all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with 6 futures. |
static CompositeFuture |
all(List<Future> futures)
Like
all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with 3 futures. |
static <T1,T2,T3,T4> |
any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with 6 futures. |
static CompositeFuture |
any(List<Future> futures)
Like
any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>) but with a list of futures. |
Throwable |
cause(int index)
Returns a cause of a wrapped future
|
boolean |
failed(int index)
Returns true if a wrapped future is failed
|
Object |
getDelegate() |
boolean |
isComplete(int index)
Returns true if a wrapped future is completed
|
static CompositeFuture |
newInstance(CompositeFuture arg) |
<T> T |
result(int index)
Returns the result of a wrapped future
|
CompositeFuture |
setHandler(Handler<AsyncResult<CompositeFuture>> handler)
Set a handler for the result.
|
Observable<CompositeFuture> |
setHandlerObservable()
Set a handler for the result.
|
int |
size() |
boolean |
succeeded(int index)
Returns true if a wrapped future is succeeded
|
cause, complete, complete, completer, compose, compose, fail, fail, failed, failedFuture, future, isComplete, map, map, newInstance, result, succeeded, succeededFuture, succeededFuture
public CompositeFuture(CompositeFuture delegate)
public Object getDelegate()
getDelegate
in class Future<CompositeFuture>
public static <T1,T2> CompositeFuture all(Future<T1> f1, Future<T2> f2)
f1
or f2
fails.f1
- futuref2
- futurepublic static <T1,T2,T3> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3)
all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 3 futures.f1
- f2
- f3
- public static <T1,T2,T3,T4> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4)
all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 4 futures.f1
- f2
- f3
- f4
- public static <T1,T2,T3,T4,T5> CompositeFuture all(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5)
all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 5 futures.f1
- f2
- f3
- f4
- f5
- public 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 6 futures.f1
- f2
- f3
- f4
- f5
- f6
- public static CompositeFuture all(List<Future> futures)
all(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with a list of futures.When the list is empty, the returned future will be already completed.
futures
- public static <T1,T2> CompositeFuture any(Future<T1> f1, Future<T2> f2)
f1
or f2
succeeds.f1
- futuref2
- futurepublic static <T1,T2,T3> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3)
any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 3 futures.f1
- f2
- f3
- public static <T1,T2,T3,T4> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4)
any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 4 futures.f1
- f2
- f3
- f4
- public static <T1,T2,T3,T4,T5> CompositeFuture any(Future<T1> f1, Future<T2> f2, Future<T3> f3, Future<T4> f4, Future<T5> f5)
any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 5 futures.f1
- f2
- f3
- f4
- f5
- public 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(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with 6 futures.f1
- f2
- f3
- f4
- f5
- f6
- public static CompositeFuture any(List<Future> futures)
any(io.vertx.rxjava.core.Future<T1>, io.vertx.rxjava.core.Future<T2>)
but with a list of futures.When the list is empty, the returned future will be already completed.
futures
- public CompositeFuture setHandler(Handler<AsyncResult<CompositeFuture>> handler)
Future
If the future has already been completed it will be called immediately. Otherwise it will be called when the future is completed.
setHandler
in class Future<CompositeFuture>
handler
- the Handler that will be called with the resultpublic Observable<CompositeFuture> setHandlerObservable()
Future
If the future has already been completed it will be called immediately. Otherwise it will be called when the future is completed.
setHandlerObservable
in class Future<CompositeFuture>
public Throwable cause(int index)
index
- the wrapped future indexpublic boolean succeeded(int index)
index
- the wrapped future indexpublic boolean failed(int index)
index
- the wrapped future indexpublic boolean isComplete(int index)
index
- the wrapped future indexpublic <T> T result(int index)
index
- the wrapped future indexpublic int size()
public static CompositeFuture newInstance(CompositeFuture arg)
Copyright © 2016. All rights reserved.