org.feijoas.mango.common.util.concurrent

Futures

Related Doc: package concurrent

object Futures

Utility functions for the work with Future[T] and Guava FutureCallback[T], ListenableFuture[T]

Usage example for conversion between Guava and Mango:

// convert a Scala Future[T] to a Guava ListenableFuture[Int]
val scalaFuture: Future[Int] = future { ... }
val guavaFuture: ListenableFuture[Int] = scalaFuture.asJava

// convert a Scala Try[T] => U to a Guava FutureCallback[T]
val callback: Try[T] => U = { ... }
val guavaCallback: FutureCallback[T] = callback.asJava

// convert a Guava ListenableFuture[Int] to a Scala Future[T]
val guavaFuture: ListenableFuture[T] = ...
val scalaFuture: Future[Int] = guavaFuture.asScala
Since

0.7

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Futures
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  4. implicit def asGuavaFutureCallbackConverter[T, U](callback: (Try[T]) ⇒ U): AsJava[FutureCallback[T]]

    Adds an asJava method that wraps a Scala function Try[T] => U in a Guava FutureCallback[T].

    Adds an asJava method that wraps a Scala function Try[T] => U in a Guava FutureCallback[T].

    The returned Guava FutureCallback[T] forwards all method calls to the provided Scala function Try[T] => U.

    callback

    the Scala function Try[T] => U to wrap in a Guava FutureCallback[T]

    returns

    An object with an asJava method that returns a Guava FutureCallback[T] view of the argument

  5. implicit def asGuavaFutureConverter[T](future: Future[T]): AsJava[ListenableFuture[T]]

    Adds an asJava method that wraps a Scala Future[T] in a Guava ListenableFuture[T].

    Adds an asJava method that wraps a Scala Future[T] in a Guava ListenableFuture[T].

    The returned Guava ListenableFuture[T] forwards all method calls to the provided Future[T].

    Note: A call on the method cancel has no effect since it cannot be delegated to the Scala Future[T]

    future

    the Scala Future[T] to wrap in a Guava ListenableFuture[T]

    returns

    An object with an asJava method that returns a Guava ListenableFuture[T] view of the argument

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. implicit def asScalaFutureConverter[T](future: ListenableFuture[T]): AsScala[Future[T]]

    Adds an asScala method that wraps Guava ListenableFuture[T] in a Scala Future[T].

    Adds an asScala method that wraps Guava ListenableFuture[T] in a Scala Future[T].

    The returned Scala Future[T] forwards all method calls to the provided Guava ListenableFuture[T].

    returns

    An object with an asScala method that returns a Scala Future[T] view of the argument

  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  9. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  10. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  11. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  12. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  13. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  14. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  15. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  16. final def notify(): Unit

    Definition Classes
    AnyRef

  17. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  18. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  19. def toString(): String

    Definition Classes
    AnyRef → Any

  20. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  21. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  22. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped