Packages

final class IORuntimeBuilder extends IORuntimeBuilderPlatform

Builder object for creating custom IORuntimes. Useful for creating IORuntime based on the default one but with some wrappers around execution contexts or custom shutdown hooks.

Source
IORuntimeBuilder.scala
Linear Supertypes
IORuntimeBuilderPlatform, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IORuntimeBuilder
  2. IORuntimeBuilderPlatform
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new IORuntimeBuilder(customCompute: Option[(ExecutionContext, () => Unit)] = None, computeTransform: (ExecutionContext) => ExecutionContext = identity, customBlocking: Option[(ExecutionContext, () => Unit)] = None, blockingTransform: (ExecutionContext) => ExecutionContext = identity, customConfig: Option[IORuntimeConfig] = None, customScheduler: Option[(Scheduler, () => Unit)] = None, extraShutdownHooks: List[() => Unit] = Nil, builderExecuted: Boolean = false, failureReporter: (Throwable) => Unit = _.printStackTrace())
    Attributes
    protected

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. def addShutdownHook(shutdown: () => Unit): IORuntimeBuilder

    Introduce additional shutdown hook to be executed after compute, blocking and scheduler shutdown logic is invoked

    Introduce additional shutdown hook to be executed after compute, blocking and scheduler shutdown logic is invoked

    shutdown

    the shutdown hook executed upon IORuntime shutdown

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. var blockingTransform: (ExecutionContext) => ExecutionContext
    Attributes
    protected
  7. def build(): IORuntime
  8. var builderExecuted: Boolean
    Attributes
    protected
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  10. var computeTransform: (ExecutionContext) => ExecutionContext
    Attributes
    protected
  11. var customBlocking: Option[(ExecutionContext, () => Unit)]
    Attributes
    protected
  12. var customCompute: Option[(ExecutionContext, () => Unit)]
    Attributes
    protected
  13. var customConfig: Option[IORuntimeConfig]
    Attributes
    protected
  14. var customScheduler: Option[(Scheduler, () => Unit)]
    Attributes
    protected
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  17. var extraShutdownHooks: List[() => Unit]
    Attributes
    protected
  18. var failureReporter: (Throwable) => Unit
    Attributes
    protected
  19. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  20. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  21. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  26. def platformSpecificBuild: IORuntime
    Attributes
    protected
    Definition Classes
    IORuntimeBuilderPlatform
  27. def setBlocking(blocking: ExecutionContext, shutdown: () => Unit): IORuntimeBuilder

    Override the default blocking execution context

    Override the default blocking execution context

    blocking

    the ExecutionContext for blocking operations

    shutdown

    ExecutionContext shutdown hook

  28. def setCompute(compute: ExecutionContext, shutdown: () => Unit): IORuntimeBuilder

    Set a custom compute pool

    Set a custom compute pool

    compute

    the ExecutionContext for the compute pool

    shutdown

    IORuntime shutdown hook

  29. def setConfig(config: IORuntimeConfig): IORuntimeBuilder

    Provide custom IORuntimeConfig for created IORuntime

    Provide custom IORuntimeConfig for created IORuntime

    config

    the runtime configuration

  30. def setFailureReporter(f: (Throwable) => Unit): IORuntimeBuilder
  31. def setScheduler(scheduler: Scheduler, shutdown: () => Unit): IORuntimeBuilder

    Override the default scheduler

    Override the default scheduler

    scheduler

    the custom scheduler

    shutdown

    Scheduler shutdown hook

  32. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  33. def toString(): String
    Definition Classes
    AnyRef → Any
  34. def transformBlocking(transform: (ExecutionContext) => ExecutionContext): IORuntimeBuilder

    Modifies the execution underlying blocking execution context.

    Modifies the execution underlying blocking execution context. Useful in case you want to use the default blocking context but add extra logic to execute, e.g. for adding instrumentation.

    transform

    the modification of the current blocking execution context

  35. def transformCompute(transform: (ExecutionContext) => ExecutionContext): IORuntimeBuilder

    Modifies the execution underlying execution context.

    Modifies the execution underlying execution context. Useful in case you want to use the default compute but add extra logic to execute, e.g. for adding instrumentation.

    transform

    the modification of the current compute execution context

  36. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from IORuntimeBuilderPlatform

Inherited from AnyRef

Inherited from Any

Ungrouped