Trait/Object

s_mach.concurrent.impl

FutureOps

Related Docs: object FutureOps | package impl

Permalink

trait FutureOps extends AnyRef

Linear Supertypes
AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FutureOps
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. val _unit: Future[Unit]

    Permalink
  5. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  6. def background[A](self: Future[A])(implicit ec: ExecutionContext): Unit

    Permalink

    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

    Annotations
    @inline()
  7. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. def firstSuccess[A](xa: Traversable[Future[A]])(implicit ec: ExecutionContext): Future[A]

    Permalink

    returns

    the first successfully completed future. If all futures fail, then completes the future with AsyncParThrowable of all failures.

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

    Permalink

    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.

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

    Permalink

    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.

  14. def get[A](self: Future[A], max: Duration): A

    Permalink

    returns

    the result of the Future after it completes

    Annotations
    @inline()
    Exceptions thrown

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

  15. def get[A](self: Future[A]): A

    Permalink

    returns

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

    Annotations
    @inline()
    Exceptions thrown

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

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

    Permalink
    Definition Classes
    AnyRef → Any
  17. def getTry[A](self: Future[A], max: Duration): Try[A]

    Permalink

    returns

    the Try result of the Future after it completes

    Annotations
    @inline()
    Exceptions thrown

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

  18. def getTry[A](self: Future[A]): Try[A]

    Permalink

    returns

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

    Annotations
    @inline()
  19. def happensBefore[A](lhs: Future[Any], rhs: ⇒ Future[A])(implicit ec: ExecutionContext): DeferredFuture[A]

    Permalink

    returns

    a future of A that is guaranteed to happen before lhs

  20. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  21. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  22. def nanoSpinDelay(delay_ns: Long): Long

    Permalink

    returns

    after spinning the current thread for delay_ns, returns the error between the requested delay and the actual delay. Use this function only when a precise delay is more important than overall performance.

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

    Permalink
    Definition Classes
    AnyRef
  24. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  25. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  26. def onTimeout[A](self: Future[A], timeout: FiniteDuration)(fallback: ⇒ Future[A])(implicit ec: ExecutionContext, sec: ScheduledExecutionContext): Future[A]

    Permalink

    returns

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

  27. def sideEffect[A](self: Future[A], sideEffect: ⇒ Unit)(implicit ec: ExecutionContext): Future[A]

    Permalink

    returns

    a future that completes once the supplied Future and the supplied side effect complete. The side effect runs after the supplied future completes even if it fails.

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

    Permalink
    Definition Classes
    AnyRef
  29. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  30. def toTry[A](self: Future[A])(implicit ec: ExecutionContext): Future[Try[A]]

    Permalink

    returns

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

  31. def unit: Future[Unit]

    Permalink
    Annotations
    @inline()
  32. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped