Packages

p

com.mchange.sc.v2

concurrent

package concurrent

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

Type Members

  1. type CBF[T] = CanBuildFrom[Seq[Future[Try[T]]], Try[T], Seq[Try[T]]]
  2. implicit final class FutureOps[T] extends AnyVal
  3. sealed trait ManagedFuture[T] extends Future[T]
  4. trait Poller extends AutoCloseable
  5. trait Scheduler extends AutoCloseable

Value Members

  1. def awaitAndGatherFailures[T](seq: Seq[Future[T]], timeout: Duration = Duration.Inf)(implicit cbf: CBF[T], ec: ExecutionContext): Seq[Throwable]
  2. def awaitAndGatherIndexedFailures[L, T](seq: Seq[Future[T]], timeout: Duration = Duration.Inf)(implicit cbf: CBF[T], ec: ExecutionContext): Seq[(Int, Throwable)]
  3. def awaitAndGatherLabeledFailures[L, T](pairs: Iterable[(L, Future[T])], timeout: Duration = Duration.Inf)(implicit cbf: CBF[T], ec: ExecutionContext): Seq[(L, Throwable)]
  4. def awaitSeq[T](seq: Seq[Future[T]], timeout: Duration = Duration.Inf)(implicit cbf: CBF[T], ec: ExecutionContext): Unit
  5. def liftToTry[T](fut: Future[T])(implicit ec: ExecutionContext): Future[Try[T]]
  6. object ExecutionContexts
  7. object ManagedFuture

    Rather than waiting on a collection of futures, which might use up a lot of heap if the collection is very large, this class defines a "Manager" one can wait on for a collection of futures to complete.

  8. object Poller
  9. object ScheduledExecutorServicePoller
  10. object Scheduler

Inherited from AnyRef

Inherited from Any

Ungrouped