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(), extraPollers: List[(Any, () => Unit)] = Nil)
    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 addPoller(poller: Any, shutdown: () => Unit): IORuntimeBuilder
  5. 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

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

  31. 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

  32. def setConfig(config: IORuntimeConfig): IORuntimeBuilder

    Provide custom IORuntimeConfig for created IORuntime

    Provide custom IORuntimeConfig for created IORuntime

    config

    the runtime configuration

  33. def setFailureReporter(f: (Throwable) => Unit): IORuntimeBuilder
  34. def setPollingSystem(system: PollingSystem): IORuntimeBuilder

    Override the default PollingSystem

    Override the default PollingSystem

    Definition Classes
    IORuntimeBuilderPlatform
  35. def setScheduler(scheduler: Scheduler, shutdown: () => Unit): IORuntimeBuilder

    Override the default scheduler

    Override the default scheduler

    scheduler

    the custom scheduler

    shutdown

    Scheduler shutdown hook

  36. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  37. def toString(): String
    Definition Classes
    AnyRef → Any
  38. 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

  39. 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

  40. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  41. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  42. 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