Packages

trait MergeOps extends AnyRef

Linear Supertypes
AnyRef, Any
Known Subclasses
MergeOps
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MergeOps
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. def flatMerge[A, M[+AA] <: Traversable[AA], N[AA] <: TraversableOnce[AA]](zomFuture: M[Future[N[A]]])(implicit ec: ExecutionContext, cbf1: 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.

  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. def merge[A, M[+AA] <: Traversable[AA]](zomFuture: M[Future[A]])(implicit ec: ExecutionContext, cbf1: 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.

  14. def mergeAllFailures[A, M[AA] <: TraversableOnce[AA]](zomFuture: M[Future[A]])(implicit ec: ExecutionContext, cbf: CanBuildFrom[M[Future[A]], Throwable, M[Throwable]]): Future[M[Throwable]]

    returns

    all failures thrown once all futures complete (maybe empty)

  15. def mergeFailImmediately[A](p: Promise[A], zomFuture: Traversable[Future[Any]])(implicit ec: ExecutionContext): Unit

    Wait on any failure from zomFuture.

    Wait on any failure from zomFuture. Immediately after the first failure, fail the promise with AsyncParThrowable.

  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  19. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped