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

chore: Remove default parameter of AbruptStreamTerminationException (#1212)

Browse source
This commit is contained in:
He-Pin(kerr) 2024-03-21 16:02:32 +08:00 • committed by GitHub
parent 55477ac6eb
commit 4bb851db12
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -270,7 +270,7 @@ class MaterializationException(msg: String, cause: Throwable = null) extends Run
/**
* A base exception for abrupt stream termination.
*/
sealed class AbruptStreamTerminationException(msg: String, cause: Throwable = null)
sealed class AbruptStreamTerminationException(msg: String, cause: Throwable)
extends RuntimeException(msg, cause)
with NoStackTrace
@ -280,7 +280,7 @@ sealed class AbruptStreamTerminationException(msg: String, cause: Throwable = nu
* when an ActorSystem is shut down while stream processing actors are still running.
*/
final case class AbruptTerminationException(actor: ActorRef)
extends AbruptStreamTerminationException(s"Processor actor [$actor] terminated abruptly")
extends AbruptStreamTerminationException(s"Processor actor [$actor] terminated abruptly", cause = null)
/**
* Signal that the operator was abruptly terminated, usually seen as a call to `postStop` of the `GraphStageLogic` without
@ -289,7 +289,8 @@ final case class AbruptTerminationException(actor: ActorRef)
*/
final class AbruptStageTerminationException(logic: GraphStageLogic)
extends AbruptStreamTerminationException(
s"GraphStage [$logic] terminated abruptly, caused by for example materializer or actor system termination.")
s"GraphStage [$logic] terminated abruptly, caused by for example materializer or actor system termination.",
cause = null)
object ActorMaterializerSettings {