c

akka.stream

AbruptStageTerminationException

final class AbruptStageTerminationException extends AbruptStreamTerminationException

Signal that the operator was abruptly terminated, usually seen as a call to postStop of the GraphStageLogic without any of the handler callbacks seeing completion or failure from upstream or cancellation from downstream. This can happen when the actor running the graph is killed, which happens when the materializer or actor system is terminated.

Source
ActorMaterializer.scala
Linear Supertypes
AbruptStreamTerminationException, NoStackTrace, RuntimeException, Exception, Throwable, Serializable, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AbruptStageTerminationException
  2. AbruptStreamTerminationException
  3. NoStackTrace
  4. RuntimeException
  5. Exception
  6. Throwable
  7. Serializable
  8. AnyRef
  9. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AbruptStageTerminationException(logic: GraphStageLogic)

Value Members

  1. final def addSuppressed(arg0: Throwable): Unit
    Definition Classes
    Throwable
  2. def fillInStackTrace(): Throwable
    Definition Classes
    NoStackTrace → Throwable
  3. def getCause(): Throwable
    Definition Classes
    Throwable
  4. def getLocalizedMessage(): String
    Definition Classes
    Throwable
  5. def getMessage(): String
    Definition Classes
    Throwable
  6. def getStackTrace(): [StackTraceElement]
    Definition Classes
    Throwable
  7. final def getSuppressed(): [Throwable]
    Definition Classes
    Throwable
  8. def initCause(arg0: Throwable): Throwable
    Definition Classes
    Throwable
  9. def printStackTrace(arg0: PrintWriter): Unit
    Definition Classes
    Throwable
  10. def printStackTrace(arg0: PrintStream): Unit
    Definition Classes
    Throwable
  11. def printStackTrace(): Unit
    Definition Classes
    Throwable
  12. def setStackTrace(arg0: [StackTraceElement]): Unit
    Definition Classes
    Throwable
  13. def toString(): String
    Definition Classes
    Throwable → AnyRef → Any