c

akka.stream

AbruptTerminationException

final case class AbruptTerminationException(actor: ActorRef) extends AbruptStreamTerminationException with Product with Serializable

This exception signals that an actor implementing a Reactive Streams Subscriber, Publisher or Processor has been terminated without being notified by an onError, onComplete or cancel signal. This usually happens when an ActorSystem is shut down while stream processing actors are still running.

Source
ActorMaterializer.scala
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AbruptTerminationException
  2. Product
  3. Equals
  4. AbruptStreamTerminationException
  5. NoStackTrace
  6. RuntimeException
  7. Exception
  8. Throwable
  9. Serializable
  10. AnyRef
  11. 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 AbruptTerminationException(actor: ActorRef)

Value Members

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