Кошачий эффект волокна автокоррекции

Я совсем новичок в кошачьих эффектах, и я уже люблю и наслаждаюсь им:)

это о волокнах

как я увидел, что волокна можно отменить, я пытаюсь выяснить, возможно ли иметь IO со списком волокон, который при ошибке на любом из волокон может отменить остальные (не уверен, что это можно сделать с помощью чистая природа ИО)

так, например:

val job = IO("long processing")

val fibersIO: IO[NonEmptyList[String]] = NonEmptyList
  .of(job, job, job, job)
  .parTraverse(_.start)
  .flatMap(_.parTraverse(_.join))

Будет ли возможно реализовать что-то вроде этого?

fibersIO.handleErrorWith { error =>
    // cancel contained fibers
}

любая помощь / подсказка будет высоко ценится

0 ответов

Другие вопросы по тегам