pjfanning commented on code in PR #2124:
URL: https://github.com/apache/pekko/pull/2124#discussion_r2382075414
##########
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala:
##########
@@ -2270,6 +2270,81 @@ final class Flow[In, Out, Mat](delegate:
scaladsl.Flow[In, Out, Mat]) extends Gr
case ex: Throwable if predicate.test(ex) => true
})
+ /**
+ * Transform a failure signal into a stream of elements provided by a
factory function.
+ * This allows to continue processing with another stream when a failure
occurs.
+ *
+ * Since the underlying failure signal onError arrives out-of-band, it might
jump over existing elements.
+ * This operator can recover the failure signal, but not the skipped
elements, which will be dropped.
+ *
+ * '''Emits when''' element is available from the upstream or upstream is
failed and fallback Source produces an element
+ *
+ * '''Backpressures when''' downstream backpressures
+ *
+ * '''Completes when''' upstream completes or upstream failed with exception
and fallback Source completes
+ *
+ * '''Cancels when''' downstream cancels
+ *
+ * @param fallback Function which produces a Source to continue the stream
+ * @since 2.0.0
Review Comment:
* this needs to change to 1.3.0
* we'll need a PR for main branch too that changes the since annotations to
1.3.0 for these changes too
--
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]
