Import cats.effect._ import cats.syntax.all._ import scala.concurrent.duration._ def retryWithBackoff[A](ioa: IO[A], initialDelay: FiniteDuration, maxRetries: Int)

Question

Import cats.effect._ import cats.syntax.all._ import scala.concurrent.duration._ def retryWithBackoff[A](ioa: IO[A], initialDelay: FiniteDuration, maxRetries: Int)

(implicit timer: Timer[IO]): IO[A] = {

ioa.handleErrorWith { error =>
if (maxRetries > 0)
IO.sleep(initialDelay) *> retryWithBackoff(ioa, initialDelay * 2, maxRetries - 1)
else
IO.raiseError(error)
}
}
Не подойдет ?

#programming #russian #scala

0

25.03.2019

2 ответов

15 просмотров

Kirill Shelopugin

Только не *> а >> лучше

0

25.03.2019

саша кремов · Accepted Answer

саша кремов

Да я уже через полугруппуК сделал

0

25.03.2019

169 похожих чатов

Import cats.effect._ import cats.syntax.all._ import scala.concurrent.duration._ def retryWithBackoff[A](ioa: IO[A], initialDelay: FiniteDuration, maxRetries: Int)

2 ответов

Похожие вопросы