raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

chore: Add a base termination for abrupt stream termination exceptions. (#1201)

Browse source
This commit is contained in:
He-Pin(kerr) 2024-03-18 17:54:57 +08:00 • committed by GitHub
parent 537669243e
commit 5a0b2c1cfa
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

13
stream/src/main/scala/org/apache/pekko/stream/ActorMaterializer.scala
View file

@ -267,14 +267,20 @@ abstract class ActorMaterializer extends Materializer with MaterializerLoggingPr
*/
class MaterializationException(msg: String, cause: Throwable = null) extends RuntimeException(msg, cause)
/**
* A base exception for abrupt stream termination.
*/
sealed class AbruptStreamTerminationException(msg: String, cause: Throwable = null)
extends RuntimeException(msg, cause)
with NoStackTrace
/**
* 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.
*/
final case class AbruptTerminationException(actor: ActorRef)
extends RuntimeException(s"Processor actor [$actor] terminated abruptly")
with NoStackTrace
extends AbruptStreamTerminationException(s"Processor actor [$actor] terminated abruptly")
/**
* Signal that the operator was abruptly terminated, usually seen as a call to `postStop` of the `GraphStageLogic` without
@ -282,9 +288,8 @@ final case class AbruptTerminationException(actor: ActorRef)
* the actor running the graph is killed, which happens when the materializer or actor system is terminated.
*/
final class AbruptStageTerminationException(logic: GraphStageLogic)
extends RuntimeException(
extends AbruptStreamTerminationException(
s"GraphStage [$logic] terminated abruptly, caused by for example materializer or actor system termination.")
with NoStackTrace
object ActorMaterializerSettings {