raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

=str Remove the deprecation annotation on Flow#recoverWith.

Browse source
This commit is contained in:
He-Pin 2023-03-04 13:32:23 +08:00 • committed by kerr
parent f9eb8aaebf
commit 83650437cd
5 changed files with 0 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

1
stream/src/main/scala/org/apache/pekko/stream/javadsl/Flow.scala
View file

@ -1731,7 +1731,6 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr
* *
* '''Cancels when''' downstream cancels * '''Cancels when''' downstream cancels
*/ */
@nowarn("msg=deprecated")
def recoverWith(pf: PartialFunction[Throwable, _ <: Graph[SourceShape[Out], NotUsed]]): javadsl.Flow[In, Out, Mat] = def recoverWith(pf: PartialFunction[Throwable, _ <: Graph[SourceShape[Out], NotUsed]]): javadsl.Flow[In, Out, Mat] =
new Flow(delegate.recoverWith(pf)) new Flow(delegate.recoverWith(pf))

3
stream/src/main/scala/org/apache/pekko/stream/javadsl/Source.scala
View file

@ -2275,9 +2275,6 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[
* *
* @deprecated use `recoverWithRetries` instead * @deprecated use `recoverWithRetries` instead
*/ */
@Deprecated
@deprecated("Use recoverWithRetries instead.", "Akka 2.6.6")
@nowarn("msg=deprecated")
def recoverWith(pf: PartialFunction[Throwable, _ <: Graph[SourceShape[Out], NotUsed]]): Source[Out, Mat] = def recoverWith(pf: PartialFunction[Throwable, _ <: Graph[SourceShape[Out], NotUsed]]): Source[Out, Mat] =
new Source(delegate.recoverWith(pf)) new Source(delegate.recoverWith(pf))

1
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubFlow.scala
View file

@ -1067,7 +1067,6 @@ class SubFlow[In, Out, Mat](
* *
* '''Cancels when''' downstream cancels * '''Cancels when''' downstream cancels
*/ */
@deprecated("Use recoverWithRetries instead.", "2.4.4")
def recoverWith( def recoverWith(
pf: PartialFunction[Throwable, Graph[SourceShape[Out], NotUsed]]): SubFlow[In, Out, Mat @uncheckedVariance] = pf: PartialFunction[Throwable, Graph[SourceShape[Out], NotUsed]]): SubFlow[In, Out, Mat @uncheckedVariance] =
new SubFlow(delegate.recoverWith(pf)) new SubFlow(delegate.recoverWith(pf))

1
stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala
View file

@ -1050,7 +1050,6 @@ class SubSource[Out, Mat](
* *
* '''Cancels when''' downstream cancels * '''Cancels when''' downstream cancels
*/ */
@deprecated("Use recoverWithRetries instead.", "2.4.4")
def recoverWith(pf: PartialFunction[Throwable, Graph[SourceShape[Out], NotUsed]]): SubSource[Out, Mat] = def recoverWith(pf: PartialFunction[Throwable, Graph[SourceShape[Out], NotUsed]]): SubSource[Out, Mat] =
new SubSource(delegate.recoverWith(pf)) new SubSource(delegate.recoverWith(pf))

1
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Flow.scala
View file

@ -886,7 +886,6 @@ trait FlowOps[+Out, +Mat] {
* *
* '''Cancels when''' downstream cancels * '''Cancels when''' downstream cancels
*/ */
@deprecated("Use recoverWithRetries instead.", "2.4.4")
def recoverWith[T >: Out](pf: PartialFunction[Throwable, Graph[SourceShape[T], NotUsed]]): Repr[T] = def recoverWith[T >: Out](pf: PartialFunction[Throwable, Graph[SourceShape[T], NotUsed]]): Repr[T] =
via(new RecoverWith(-1, pf)) via(new RecoverWith(-1, pf))