This is an automated email from the ASF dual-hosted git repository. hepin pushed a commit to branch rec in repository https://gitbox.apache.org/repos/asf/pekko.git
commit 4933995686e6b081b52abd7d2ad3a6df314e4fb7 Author: He-Pin <[email protected]> AuthorDate: Sun Aug 31 14:24:12 2025 +0800 chore: Remove the deprecated annotation from recoverWith --- stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala | 3 --- stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala | 6 ------ 2 files changed, 9 deletions(-) diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala index 4eedf5f2ca..7a2ec9018e 100755 --- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala @@ -1981,10 +1981,7 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr * '''Completes when''' upstream completes or upstream failed with exception pf can handle * * '''Cancels when''' downstream cancels - * - * @deprecated use `recoverWithRetries` instead */ - @deprecated("Use recoverWithRetries instead.", "Akka 2.6.6") def recoverWith( clazz: Class[_ <: Throwable], supplier: Supplier[Graph[SourceShape[Out], NotUsed]]): javadsl.Flow[In, Out, Mat] = diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala index cb940dc047..baf5c23e91 100755 --- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala @@ -2196,8 +2196,6 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[ * '''Completes when''' upstream completes or upstream failed with exception pf can handle * * '''Cancels when''' downstream cancels - * - * @deprecated use `recoverWithRetries` instead */ def recoverWith(pf: PartialFunction[Throwable, _ <: Graph[SourceShape[Out], NotUsed]]): Source[Out, Mat] = new Source(delegate.recoverWith(pf)) @@ -2220,11 +2218,7 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[ * '''Completes when''' upstream completes or upstream failed with exception pf can handle * * '''Cancels when''' downstream cancels - * - * @deprecated use `recoverWithRetries` instead */ - @deprecated("Use recoverWithRetries instead.", "Akka 2.6.6") - @nowarn("msg=deprecated") def recoverWith( clazz: Class[_ <: Throwable], supplier: Supplier[Graph[SourceShape[Out], NotUsed]]): Source[Out, Mat] = --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
