Package | Description |
---|---|
io.vertx.reactivex.core |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<CompositeFuture> |
CompositeFuture.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static <T1,T2> CompositeFuture |
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 |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
all(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
all(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) 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)
Like
all(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) 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)
Like
all(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with 6 futures. |
static CompositeFuture |
CompositeFuture.all(List<Future> futures)
Like
all(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with a list of futures. |
static <T1,T2> CompositeFuture |
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 |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
any(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
any(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) 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)
Like
any(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) 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)
Like
any(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with 6 futures. |
static CompositeFuture |
CompositeFuture.any(List<Future> futures)
Like
any(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with a list of futures. |
static <T1,T2> CompositeFuture |
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 |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
join(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
join(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) 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)
Like
join(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) 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)
Like
join(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with 6 futures. |
static CompositeFuture |
CompositeFuture.join(List<Future> futures)
Like
join(io.vertx.reactivex.core.Future<T1>, io.vertx.reactivex.core.Future<T2>) but with a list of futures. |
static CompositeFuture |
CompositeFuture.newInstance(CompositeFuture arg) |
CompositeFuture |
CompositeFuture.onComplete(Handler<AsyncResult<CompositeFuture>> handler) |
CompositeFuture |
CompositeFuture.onFailure(Handler<Throwable> handler) |
CompositeFuture |
CompositeFuture.onSuccess(Handler<CompositeFuture> handler) |
CompositeFuture |
CompositeFuture.result()
The result of the operation.
|
CompositeFuture |
CompositeFuture.setHandler(Handler<AsyncResult<CompositeFuture>> handler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Handler<AsyncResult<CompositeFuture>> |
CompositeFuture.completer()
Deprecated.
|
Future<CompositeFuture> |
CompositeFuture.otherwise(CompositeFuture value)
Map the failure of a future to a specific
value . |
Future<CompositeFuture> |
CompositeFuture.otherwise(java.util.function.Function<Throwable,CompositeFuture> mapper)
Apply a
mapper function on this future. |
Future<CompositeFuture> |
CompositeFuture.otherwiseEmpty()
Map the failure of a future to
null . |
Future<CompositeFuture> |
CompositeFuture.recover(java.util.function.Function<Throwable,Future<CompositeFuture>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Single<CompositeFuture> |
CompositeFuture.rxOnComplete() |
Single<CompositeFuture> |
CompositeFuture.rxSetHandler()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeFuture.complete(CompositeFuture result)
Deprecated.
|
Future<CompositeFuture> |
CompositeFuture.otherwise(CompositeFuture value)
Map the failure of a future to a specific
value . |
boolean |
CompositeFuture.tryComplete(CompositeFuture result)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
<U> Future<U> |
CompositeFuture.compose(java.util.function.Function<CompositeFuture,Future<U>> mapper)
Compose this future with a
mapper function. |
<U> Future<U> |
CompositeFuture.compose(java.util.function.Function<CompositeFuture,Future<U>> successMapper,
java.util.function.Function<Throwable,Future<U>> failureMapper)
Compose this future with a
successMapper and failureMapper functions. |
<U> Future<U> |
CompositeFuture.flatMap(java.util.function.Function<CompositeFuture,Future<U>> mapper)
|
<U> Future<U> |
CompositeFuture.map(java.util.function.Function<CompositeFuture,U> mapper)
Apply a
mapper function on this future. |
CompositeFuture |
CompositeFuture.onComplete(Handler<AsyncResult<CompositeFuture>> handler) |
CompositeFuture |
CompositeFuture.onSuccess(Handler<CompositeFuture> handler) |
Future<CompositeFuture> |
CompositeFuture.otherwise(java.util.function.Function<Throwable,CompositeFuture> mapper)
Apply a
mapper function on this future. |
Future<CompositeFuture> |
CompositeFuture.recover(java.util.function.Function<Throwable,Future<CompositeFuture>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
CompositeFuture |
CompositeFuture.setHandler(Handler<AsyncResult<CompositeFuture>> handler)
Deprecated.
|
Copyright © 2023 Eclipse. All rights reserved.