diff --git a/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs b/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs index c97c51cb558..5b6c72aaf55 100644 --- a/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs +++ b/src/core/Akka.Streams/Implementation/Fusing/ActorGraphInterpreter.cs @@ -767,7 +767,9 @@ public AsyncInput(GraphInterpreterShell shell, GraphStageLogic logic, object @ev public GraphInterpreterShell Shell { get; } } - private class ShellRegistered + // This is the Resume internal API message in JVM, it is used to prevent/short circuit recursive calls + // inside a stream. Harmless when dead-lettered. + private class ShellRegistered: IDeadLetterSuppression { public static readonly ShellRegistered Instance = new(); private ShellRegistered()