open class CompositeFuture : Future<CompositeFuture>
The composite future wraps a list of io.vertx.reactivex.core.Future, 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. NOTE: This class has been automatically generated from the io.vertx.core.CompositeFuture non RX-ified interface using Vert.x codegen.
CompositeFuture(delegate: CompositeFuture) |
static val __TYPE_ARG: TypeArg<CompositeFuture> |
val __typeArg_0: TypeArg<T> |
open static fun <T1 : Any, T2 : Any> all(f1: Future<T1>, f2: Future<T2>): CompositeFuture
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed. The returned future fails as soon as one of open static fun <T1 : Any, T2 : Any, T3 : Any> all(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any> all(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any, T5 : Any> all(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>, f5: Future<T5>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any, T5 : Any, T6 : Any> all(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>, f5: Future<T5>, f6: Future<T6>): CompositeFuture
Like open static fun all(futures: MutableList<Future<Any>>): CompositeFuture
Like When the list is empty, the returned future will be already completed. |
|
open static fun <T1 : Any, T2 : Any> any(f1: Future<T1>, f2: Future<T2>): CompositeFuture
Return a composite future, succeeded when any futures is succeeded, failed when all futures are failed. The returned future succeeds as soon as one of open static fun <T1 : Any, T2 : Any, T3 : Any> any(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any> any(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any, T5 : Any> any(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>, f5: Future<T5>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any, T5 : Any, T6 : Any> any(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>, f5: Future<T5>, f6: Future<T6>): CompositeFuture
Like open static fun any(futures: MutableList<Future<Any>>): CompositeFuture
Like When the list is empty, the returned future will be already completed. |
|
open fun cause(index: Int): Throwable
Returns a cause of a wrapped future |
|
open fun complete(result: CompositeFuture): Unit
Set the result. Any handler will be called, if there is one, and the future will be marked as completed. open fun complete(): Unit
Set this instance as result. Any handler will be called, if there is one, and the future will be marked as completed. |
|
open fun completer(): Handler<AsyncResult<CompositeFuture>> |
|
open fun <U : Any> compose(handler: Handler<CompositeFuture>, next: Future<U>): Future<U>
Compose this future with a provided When this (the one on which If the When this future fails, the failure will be propagated to the open fun <U : Any> compose(mapper: Function<CompositeFuture, Future<U>>): Future<U>
Compose this future with a When this future (the one on which If the When this future fails, the failure will be propagated to the returned future and the |
|
open fun equals(other: Any?): Boolean |
|
open fun failed(index: Int): Boolean
Returns true if a wrapped future is failed |
|
open fun getDelegate(): CompositeFuture |
|
open fun hashCode(): Int |
|
open fun isComplete(index: Int): Boolean
Returns true if a wrapped future is completed |
|
open static fun <T1 : Any, T2 : Any> join(f1: Future<T1>, f2: Future<T2>): CompositeFuture
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed. It always wait until all its futures are completed and will not fail as soon as one of open static fun <T1 : Any, T2 : Any, T3 : Any> join(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any> join(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any, T5 : Any> join(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>, f5: Future<T5>): CompositeFuture
Like open static fun <T1 : Any, T2 : Any, T3 : Any, T4 : Any, T5 : Any, T6 : Any> join(f1: Future<T1>, f2: Future<T2>, f3: Future<T3>, f4: Future<T4>, f5: Future<T5>, f6: Future<T6>): CompositeFuture
Like open static fun join(futures: MutableList<Future<Any>>): CompositeFuture
Like When the list is empty, the returned future will be already completed. |
|
open fun <U : Any> map(mapper: Function<CompositeFuture, U>): Future<U>
Apply a When this future succeeds, the If the When this future fails, the failure will be propagated to the returned future and the |
|
open static fun newInstance(arg: CompositeFuture): CompositeFuture |
|
open fun otherwise(mapper: Function<Throwable, CompositeFuture>): Future<CompositeFuture>
Apply a When this future fails, the If the When this future succeeds, the result will be propagated to the returned future and the open fun otherwise(value: CompositeFuture): Future<CompositeFuture>
Map the failure of a future to a specific When this future fails, this When this future succeeds, the result will be propagated to the returned future. |
|
open fun otherwiseEmpty(): Future<CompositeFuture>
Map the failure of a future to This is a convenience for When this future fails, the When this future succeeds, the result will be propagated to the returned future. |
|
open fun recover(mapper: Function<Throwable, Future<CompositeFuture>>): Future<CompositeFuture>
Handles a failure of this Future by returning the result of another Future. If the mapper fails, then the returned future will be failed with this failure. |
|
open fun result(): CompositeFuture
The result of the operation. This will be null if the operation failed. |
|
open fun <T : Any> resultAt(index: Int): T
Returns the result of a wrapped future |
|
open fun rxSetHandler(): Single<CompositeFuture> |
|
open fun setHandler(handler: Handler<AsyncResult<CompositeFuture>>): CompositeFuture |
|
open fun size(): Int |
|
open fun succeeded(index: Int): Boolean
Returns true if a wrapped future is succeeded |
|
open fun toString(): String |
|
open fun tryComplete(result: CompositeFuture): Boolean
Set the failure. Any handler will be called, if there is one, and the future will be marked as completed. open fun tryComplete(): Boolean
Try to set this instance as result. When it happens, any handler will be called, if there is one, and the future will be marked as completed. |
open fun cause(): Throwable
A Throwable describing failure. This will be null if the operation succeeded. |
|
open fun fail(cause: Throwable): Unit
Set the failure. Any handler will be called, if there is one, and the future will be marked as completed. open fun fail(failureMessage: String): Unit
Try to set the failure. When it happens, any handler will be called, if there is one, and the future will be marked as completed. |
|
open fun failed(): Boolean
Did it fail? |
|
open static fun <T : Any> failedFuture(t: Throwable): Future<T>
Create a failed future with the specified failure cause. open static fun <T : Any> failedFuture(failureMessage: String): Future<T>
Create a failed future with the specified failure message. |
|
open static fun <T : Any> future(handler: Handler<Future<T>>): Future<T>
Create a future that hasn't completed yet and that is passed to the open static fun <T : Any> future(): Future<T>
Create a future that hasn't completed yet |
|
open fun isComplete(): Boolean
Has the future completed? It's completed if it's either succeeded or failed. |
|
open fun <V : Any> map(value: V): Future<V>
Map the result of a future to a specific When this future succeeds, this When this future fails, the failure will be propagated to the returned future. |
|
open fun <V : Any> mapEmpty(): Future<V>
Map the result of a future to This is a conveniency for When this future succeeds, When this future fails, the failure will be propagated to the returned future. |
|
open static fun <T : Any> newInstance(arg: Future<Any>): Future<T>open static fun <T : Any> newInstance(arg: Future<Any>, __typeArg_T: TypeArg<T>): Future<T> |
|
open fun succeeded(): Boolean
Did it succeed? |
|
open static fun <T : Any> succeededFuture(): Future<T>
Create a succeeded future with a null result open static fun <T : Any> succeededFuture(result: T): Future<T>
Created a succeeded future with the specified result. |
|
open fun tryFail(failureMessage: String): Booleanopen fun tryFail(cause: Throwable): Boolean
Try to set the failure. When it happens, any handler will be called, if there is one, and the future will be marked as completed. |