package concurrent
- Alphabetic
- Public
- All
Type Members
- case class ExecutionEnv(executorServices: ExecutorServices, timeFactor: Int) extends Product with Serializable
- case class ExecutorServices(executorServiceEval: Evaluated[ExecutorService], executionContextEval: Evaluated[ExecutionContext], scheduledExecutorServiceEval: Evaluated[ScheduledExecutorService], schedulerEval: Evaluated[Scheduler], shutdown: Evaluated[Unit]) extends Product with Serializable
- trait FutureApplicative extends AnyRef
-
trait
FutureAwait extends AnyRef
implicit methods to await a future values with a given timeout and number of retries
- trait ImplicitExecutionContextFromExecutionEnv extends AnyRef
-
trait
ImplicitExecutionContexts extends ImplicitExecutionContextFromExecutionEnv with ImplicitExecutorServiceFromExecutionEnv
add implicit conversions between the execution environment and execution context / executor service
- trait ImplicitExecutorServiceFromExecutionEnv extends AnyRef
-
trait
NoImplicitExecutionContextFromExecutionEnv extends ImplicitExecutionContextFromExecutionEnv
deactivate the conversion between an implicit execution environment to an execution context
-
trait
NoImplicitExecutorServiceFromExecutionEnv extends ImplicitExecutorServiceFromExecutionEnv
deactivate the conversion between an implicit execution environment to an executor service
-
trait
Scheduler extends AnyRef
The design of the Scheduler is taken from: https://github.com/functional-streams-for-scala/fs2/blob/series/1.0/core/jvm/src/main/scala/fs2/Scheduler.scala
- case class TimeoutFailure(appliedTimeout: FiniteDuration, totalDuration: FiniteDuration, timeFactor: Int) extends Product with Serializable
Value Members
- object ExecutionEnv extends Serializable
- object ExecutorServices extends Serializable
- object FutureApplicative extends FutureApplicative
- object FutureAwait extends FutureAwait
- object Schedulers