кошачий эффект волокна автокоррекции - PullRequest
0 голосов
/ 07 июня 2018

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

это примерно волокон

, как я виделчто волокна могут быть отменены, я пытаюсь увидеть, возможно ли иметь IO со списком волокон, которые при ошибке на любом из волокон могут отменить остальные (не уверен, что это можно сделать с чистой природой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
}

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

...