trait FutureContext[E <: Env[E]] extends AnyRef
FutureContext contains functions for creating and combining E#FutureUnlessShutdown that will be safe to use in pipeToSelf.
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- FutureContext
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Abstract Value Members
- abstract def flatMapFuture[R1, R2](future1: E.FutureUnlessShutdownT[R1], future2: PureFun[R1, E.FutureUnlessShutdownT[R2]]): E.FutureUnlessShutdownT[R2]
flatMapFuture requires a PureFun instead of a normal scala.Function1 for similar reason as mapFuture
- abstract def mapFuture[X, Y](future: E.FutureUnlessShutdownT[X])(fun: PureFun[X, Y]): E.FutureUnlessShutdownT[Y]
mapFuture requires a PureFun instead of a normal scala.Function1 since we need to be careful not to mutate state of the modules in the Env#FutureUnlessShutdownT, as this would violate the assumptions we use when writing Modules.
- abstract def pureFuture[X](x: X): E.FutureUnlessShutdownT[X]
- abstract def sequenceFuture[A, F[_]](futures: F[E.FutureUnlessShutdownT[A]])(implicit ev: Traverse[F]): E.FutureUnlessShutdownT[F[A]]
- abstract def timeFuture[X](timer: Timer, futureUnlessShutdown: => E.FutureUnlessShutdownT[X])(implicit mc: MetricsContext): E.FutureUnlessShutdownT[X]
- abstract def zipFuture[X, Y, Z](future1: E.FutureUnlessShutdownT[X], future2: E.FutureUnlessShutdownT[Y], future3: E.FutureUnlessShutdownT[Z]): E.FutureUnlessShutdownT[(X, Y, Z)]
- abstract def zipFuture[X, Y](future1: E.FutureUnlessShutdownT[X], future2: E.FutureUnlessShutdownT[Y]): E.FutureUnlessShutdownT[(X, Y)]
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])