Реализация отменяемого setInterval с использованием таймера кошачьего эффекта
Это то, что я пытался, но после первого сна его нельзя отменить.
import cats.syntax.all._
import cats.effect._
import scala.concurrent.duration._
import scala.language.higherKinds
object Foo {
def setInterval[F[_]](duration: FiniteDuration)(
fa: F[Unit]
)(implicit F: ConcurrentEffect[F], T: Timer[F]): F[IO[Unit]] = {
def run: F[Unit] = {
T.sleep(duration) *>
F.liftIO(F.runAsync(F.suspend(run))(_ => IO.unit)) *> fa
}
F.liftIO(F.runCancelable(run)(_ => IO.unit))
}
}
Как я могу реализовать настоящий отменяемый setInterval
?
1 ответ
С помощью Фабио Лабеллы я узнал
F.liftIO(F.runAsync(F.suspend(run))(_ => IO.unit)) *> fa
runAsync
просто сделайте следующий рекурсивный вызов запущенным в фоновом режиме и будьте неисключаемы, поэтому мне пришлось сделать fa
на заднем плане, просто так
F.liftIO(F.runAsync(fa)(_ => IO.unit)) *> F.suspend(run)