Packages

c

s_mach.concurrent

SMach_Concurrent_PimpMyTraversableFuture

implicit final class SMach_Concurrent_PimpMyTraversableFuture[A, M[+AA] <: Traversable[AA]] extends AnyVal

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

Instance Constructors

  1. new SMach_Concurrent_PimpMyTraversableFuture(self: M[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 firstSuccess(implicit ec: ExecutionContext): Future[A]

    returns

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

  6. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  7. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  8. def merge(implicit ec: ExecutionContext, cbf: CanBuildFrom[Nothing, A, M[A]]): Future[M[A]]

    returns

    a Future of a collection of items that completes once all futures are successful OR completes immediately after any failure. This is in contrast to Future.sequence which will only complete once *all* Futures have completed, even if one of the futures fails immediately. The first failure encountered immediately throws AsyncParThrowable which has a method to return a Future of all failures.

  9. val self: M[Future[A]]
  10. def toString(): String
    Definition Classes
    Any

Inherited from AnyVal

Inherited from Any

Ungrouped