Skip to content

Commit

Permalink
Use an explicit partial function for compatibility
Browse files Browse the repository at this point in the history
  • Loading branch information
kciesielski committed Jun 29, 2023
1 parent 3641ec2 commit 5772438
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ abstract class StreamingTest[F[_], S]
implicit val monadError: MonadError[Future] = new FutureMonad

def retryImmediatelyOnError[A](action: => Future[A], retriesLeft: Int): Future[A] =
action.handleError { error =>
action.handleError { case error =>
new Exception(s"Error in ${getClass.getSimpleName}, retries left = $retriesLeft", error).printStackTrace
if (retriesLeft > 1)
retryImmediatelyOnError(action, retriesLeft - 1)
Expand Down

0 comments on commit 5772438

Please sign in to comment.