mdedetrich commented on issue #980:
URL:
https://github.com/apache/incubator-pekko/issues/980#issuecomment-1900079808
@He-Pin But he is talking about `SubFlow`, so from what he seems to be
saying is that he just wants the `SubFlow` to have the ability to restart (and
this means by implication if the `SubFlow` is just a sink then the Sink will
restart).
Then you can just do
```scala
val restartingDecider: Supervision.Decider = { e =>
logger.error("Unhandled exception in stream, restarting", e)
Supervision.Restart
}
source
.splitAfter(_ == somePredicate)
.withAttributes(ActorAttributes.supervisionStrategy(restartingDecider))
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
