Packages

c

s_mach.concurrent

SMach_Concurrent_PimpMyFuture

implicit final class SMach_Concurrent_PimpMyFuture[A] extends AnyVal

Linear Supertypes
AnyVal, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SMach_Concurrent_PimpMyFuture
  2. AnyVal
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SMach_Concurrent_PimpMyFuture(self: Future[A])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    Any
  2. final def ##(): Int
    Definition Classes
    Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def background(implicit ec: ExecutionContext): Unit

    Run future in the background.

    Run future in the background. Discard the result of this Future but ensure if there is an exception it gets reported to the ExecutionContext

  6. def flatFold[X](onSuccess: (A) ⇒ Future[X], onFailure: (Throwable) ⇒ Future[X])(implicit ec: ExecutionContext): Future[X]

    returns

    a Future of X that always succeeds. If self is successful, X is derived from onSuccess otherwise if self is a failure, X is derived from onFailure.

  7. def fold[X](onSuccess: (A) ⇒ X, onFailure: (Throwable) ⇒ X)(implicit ec: ExecutionContext): Future[X]

    returns

    a Future of X that always succeeds. If self is successful, X is derived from onSuccess otherwise if self is a failure, X is derived from onFailure.

  8. def get(max: Duration): A

    returns

    the result of the Future after it completes

    Exceptions thrown

    java.util.concurrent.TimeoutException if Future does not complete within max duration

  9. def get: A

    returns

    the result of the Future after it completes (Note: this waits indefinitely for the Future to complete)

    Exceptions thrown

    java.lang.Exception Future completed with a failure, throws the exception

  10. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  11. def getTry(max: Duration): Try[A]

    returns

    the Try result of the Future after it completes

    Exceptions thrown

    java.util.concurrent.TimeoutException if Future does not complete within max duration

  12. def getTry: Try[A]

    returns

    the Try result of the Future after it completes (Note: this waits indefinitely for the Future to complete)

  13. def happensBefore[B](other: ⇒ Future[B])(implicit ec: ExecutionContext): DeferredFuture[B]

    returns

    a future of A that is guaranteed to happen before lhs

  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. def onTimeout(timeout: FiniteDuration)(fallback: ⇒ Future[A])(implicit ec: ExecutionContext, sec: ScheduledExecutionContext): Future[A]

    returns

    a future that completes with fallback if the specified timeout is exceeded, otherwise the completed result of the future

  16. val self: Future[A]
  17. def sideEffect(sideEffect: ⇒ Unit)(implicit ec: ExecutionContext): Future[A]

    returns

    execute a side effect after a future completes (even if it fails)

  18. def toString(): String
    Definition Classes
    Any
  19. def toTry(implicit ec: ExecutionContext): Future[Try[A]]

    returns

    a Future of a Try of the result that always completes successfully even if the Future eventually throws an exception

Inherited from AnyVal

Inherited from Any

Ungrouped