akka.stream

Supervision

object Supervision

Source
Supervision.scala
Linear Supertypes
Content Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Supervision
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. type Decider = (Throwable) ⇒ Directive

  2. sealed trait Directive extends AnyRef

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. object Restart extends Directive with Product with Serializable

    Scala API: The element is dropped and the stream continues after restarting the stage if application code for processing an element throws an exception.

  7. object Resume extends Directive with Product with Serializable

    Scala API: The element is dropped and the stream continues if application code for processing an element throws an exception.

  8. object Stop extends Directive with Product with Serializable

    Scala API: The stream will be completed with failure if application code for processing an element throws an exception.

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  15. val getRestartingDecider: Function[Throwable, Directive]

    Java API: Decider function that returns #restart for all exceptions.

  16. val getResumingDecider: Function[Throwable, Directive]

    Java API: Decider function that returns #resume for all exceptions.

  17. val getStoppingDecider: Function[Throwable, Directive]

    Java API: Decider function that returns #stop for all exceptions.

  18. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  19. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  20. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  21. final def notify(): Unit

    Definition Classes
    AnyRef
  22. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  23. def restart: Restart.type

    Java API: The element is dropped and the stream continues after restarting the stage if application code for processing an element throws an exception.

    Java API: The element is dropped and the stream continues after restarting the stage if application code for processing an element throws an exception. Restarting a stage means that any accumulated state is cleared. This is typically performed by creating a new instance of the stage.

  24. val restartingDecider: (Throwable) ⇒ Directive with Function[Throwable, Directive]

    Scala API: Decider that returns Restart for all exceptions.

  25. def resume: Resume.type

    Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.

  26. val resumingDecider: (Throwable) ⇒ Directive with Function[Throwable, Directive]

    Scala API: Decider that returns Resume for all exceptions.

  27. def stop: Stop.type

    Java API: The stream will be completed with failure if application code for processing an element throws an exception.

  28. val stoppingDecider: (Throwable) ⇒ Directive with Function[Throwable, Directive]

    Scala API: Decider that returns Stop for all exceptions.

  29. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  30. def toString(): String

    Definition Classes
    AnyRef → Any
  31. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped