He-Pin opened a new pull request, #2120: URL: https://github.com/apache/pekko/pull/2120
Motivation: refs: https://github.com/apache/pekko/issues/2116 The current `recoverWith` is using a Scala partial function, which is hard to use from the Java side, with this, we can achieve the same as `reactor-core/rxjava` friendly to Java developers. The `onErrorComplete` and `onErrorResume` are widely used in MCP Java SDK. Modification: 1. Add `onErrorResume` operator to both Source and Flow, javadsl only 2. Adjust the current FlowTest, which was testing the Source dsl, but now Flow DSL. 3. Add both Flow and Source testing for `onErrorResume` and `onErrorComplete` Result: Easy to use for Java developers. -- 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]
