class CompositeFuture extends Future[CompositeFuture]
The composite future wraps a list of io.vertx.scala.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.
- Alphabetic
- By Inheritance
- CompositeFuture
- Future
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new CompositeFuture(_asJava: AnyRef)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
asJava: AnyRef
- Definition Classes
- Future
-
def
cause(index: Int): Throwable
Returns a cause of a wrapped future * @param index the wrapped future index
-
def
cause(): Throwable
A Throwable describing failure.
A Throwable describing failure. This will be null if the operation succeeded. * @return the cause or null if the operation succeeded.
- Definition Classes
- Future
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
complete(): Unit
Set this instance as result.
Set this instance as result. Any handler will be called, if there is one, and the future will be marked as completed.
- Definition Classes
- CompositeFuture → Future
-
def
complete(result: CompositeFuture): Unit
Set the result.
Set the result. Any handler will be called, if there is one, and the future will be marked as completed. * @param result the result
- Definition Classes
- CompositeFuture → Future
-
def
completer(): Handler[AsyncResult[CompositeFuture]]
- returns
an handler completing this future
- Definition Classes
- CompositeFuture → Future
-
def
compose[U](mapper: (CompositeFuture) ⇒ Future[U])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[U]): Future[U]
Compose this future with a
mapper
function.Compose this future with a
mapper
function.When this future (the one on which
compose
is called) succeeds, themapper
will be called with the completed value and this mapper returns another future object. This returned future completion will complete the future returned by this method call.If the
mapper
throws an exception, the returned future will be failed with this exception.When this future fails, the failure will be propagated to the returned future and the
mapper
will not be called. * @param mapper the mapper function- returns
the composed future
- Definition Classes
- CompositeFuture → Future
-
def
compose[U](handler: Handler[CompositeFuture], next: Future[U])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[U]): Future[U]
Compose this future with a provided
next
future.Compose this future with a provided
next
future.When this (the one on which
compose
is called) future succeeds, thehandler
will be called with the completed value, this handler should complete the next future.If the
handler
throws an exception, the returned future will be failed with this exception.When this future fails, the failure will be propagated to the
next
future and thehandler
will not be called. * @param handler the handler- next
the next future
- returns
the next future, used for chaining
- Definition Classes
- CompositeFuture → Future
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
fail(failureMessage: String): Unit
Try to set the failure.
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. * @param failureMessage the failure message
- Definition Classes
- Future
-
def
fail(cause: Throwable): Unit
Set the failure.
Set the failure. Any handler will be called, if there is one, and the future will be marked as completed. * @param cause the failure cause
- Definition Classes
- Future
-
def
failed(index: Int): Boolean
Returns true if a wrapped future is failed * @param index the wrapped future index
-
def
failed(): Boolean
Did it fail? * @return true if it failed or false otherwise
Did it fail? * @return true if it failed or false otherwise
- Definition Classes
- Future
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
isComplete(index: Int): Boolean
Returns true if a wrapped future is completed * @param index the wrapped future index
-
def
isComplete(): Boolean
Has the future completed?
Has the future completed?
It's completed if it's either succeeded or failed. * @return true if completed, false if not
- Definition Classes
- Future
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
map[U](mapper: (CompositeFuture) ⇒ U)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[U]): Future[U]
Apply a
mapper
function on this future.Apply a
mapper
function on this future.When this future succeeds, the
mapper
will be called with the completed value and this mapper returns a value. This value will complete the future returned by this method call.If the
mapper
throws an exception, the returned future will be failed with this exception.When this future fails, the failure will be propagated to the returned future and the
mapper
will not be called. * @param mapper the mapper function- returns
the mapped future
- Definition Classes
- CompositeFuture → Future
-
def
map[V](value: V)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[V]): Future[V]
Map the result of a future to a specific
value
.Map the result of a future to a specific
value
.When this future succeeds, this
value
will complete the future returned by this method call.When this future fails, the failure will be propagated to the returned future. * @param value the value that eventually completes the mapped future
- returns
the mapped future
- Definition Classes
- Future
-
def
mapEmpty[V]()(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[V]): Future[V]
Map the result of a future to
null
.Map the result of a future to
null
.This is a conveniency for
future.map((T) null)
orfuture.map((Void) null)
.When this future succeeds,
null
will complete the future returned by this method call.When this future fails, the failure will be propagated to the returned future. * @return the mapped future
- Definition Classes
- Future
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
otherwise(value: CompositeFuture): Future[CompositeFuture]
Map the failure of a future to a specific
value
.Map the failure of a future to a specific
value
.When this future fails, this
value
will complete the future returned by this method call.When this future succeeds, the result will be propagated to the returned future. * @param value the value that eventually completes the mapped future
- returns
the mapped future
- Definition Classes
- CompositeFuture → Future
-
def
otherwise(mapper: (Throwable) ⇒ CompositeFuture): Future[CompositeFuture]
Apply a
mapper
function on this future.Apply a
mapper
function on this future.When this future fails, the
mapper
will be called with the completed value and this mapper returns a value. This value will complete the future returned by this method call.If the
mapper
throws an exception, the returned future will be failed with this exception.When this future succeeds, the result will be propagated to the returned future and the
mapper
will not be called. * @param mapper the mapper function- returns
the mapped future
- Definition Classes
- CompositeFuture → Future
-
def
otherwiseEmpty(): Future[CompositeFuture]
Map the failure of a future to
null
.Map the failure of a future to
null
.This is a convenience for
future.otherwise((T) null)
.When this future fails, the
null
value will complete the future returned by this method call.When this future succeeds, the result will be propagated to the returned future. * @return the mapped future
- Definition Classes
- CompositeFuture → Future
-
def
recover(mapper: (Throwable) ⇒ Future[CompositeFuture]): Future[CompositeFuture]
Handles a failure of this Future by returning the result of another Future.
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. * @param mapper A function which takes the exception of a failure and returns a new future.
- returns
A recovered future
- Definition Classes
- CompositeFuture → Future
-
def
result(): CompositeFuture
The result of the operation.
The result of the operation. This will be null if the operation failed. * @return the result or null if the operation failed.
- Definition Classes
- CompositeFuture → Future
-
def
resultAt[T](index: Int)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): T
Returns the result of a wrapped future * @param index the wrapped future index
-
def
setHandler(handler: Handler[AsyncResult[CompositeFuture]]): CompositeFuture
Set a handler for the result.
Set a handler for the result.
If the future has already been completed it will be called immediately. Otherwise it will be called when the future is completed. * @param handler the Handler that will be called with the result
- returns
a reference to this, so it can be used fluently
- Definition Classes
- CompositeFuture → Future
-
def
size(): Int
- returns
the number of wrapped future
-
def
succeeded(index: Int): Boolean
Returns true if a wrapped future is succeeded * @param index the wrapped future index
-
def
succeeded(): Boolean
Did it succeed? * @return true if it succeded or false otherwise
Did it succeed? * @return true if it succeded or false otherwise
- Definition Classes
- Future
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
tryComplete(): Boolean
Try to set this instance as result.
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. * @return false when the future is already completed
- Definition Classes
- CompositeFuture → Future
-
def
tryComplete(result: CompositeFuture): Boolean
Set the failure.
Set the failure. Any handler will be called, if there is one, and the future will be marked as completed. * @param result the result
- returns
false when the future is already completed
- Definition Classes
- CompositeFuture → Future
-
def
tryFail(failureMessage: String): Boolean
Try to set the failure.
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. * @param failureMessage the failure message
- returns
false when the future is already completed
- Definition Classes
- Future
-
def
tryFail(cause: Throwable): Boolean
Try to set the failure.
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. * @param cause the failure cause
- returns
false when the future is already completed
- Definition Classes
- Future
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )