From c05a3e0e265f73e430e6365a6fa0c4d45ddab1bb Mon Sep 17 00:00:00 2001 From: Richard Imaoka Date: Tue, 31 Oct 2017 00:21:44 +0900 Subject: [PATCH] Fix Scaladoc for recoverWithRetries (#23762) (#23763) --- akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala | 1 - akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala | 1 - 2 files changed, 2 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala index 752e5a62df..cc4d1365a4 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala @@ -1108,7 +1108,6 @@ final class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends * * @param attempts Maximum number of retries or -1 to retry indefinitely * @param pf Receives the failure cause and returns the new Source to be materialized if any - * @throws IllegalArgumentException if `attempts` is a negative number other than -1 */ def recoverWithRetries[T >: Out](attempts: Int, pf: PartialFunction[Throwable, _ <: Graph[SourceShape[T], NotUsed]]): javadsl.Flow[In, T, Mat @uncheckedVariance] = new Flow(delegate.recoverWithRetries(attempts, pf)) diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala index eb7df654d6..d1b678e218 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala @@ -615,7 +615,6 @@ trait FlowOps[+Out, +Mat] { * * @param attempts Maximum number of retries or -1 to retry indefinitely * @param pf Receives the failure cause and returns the new Source to be materialized if any - * @throws IllegalArgumentException if `attempts` is a negative number other than -1 * */ def recoverWithRetries[T >: Out](attempts: Int, pf: PartialFunction[Throwable, Graph[SourceShape[T], NotUsed]]): Repr[T] =