Jannis
01/20/2020, 8:27 PMraceN
correctly:
IO.fx {
dispatchers().io().raceN(timer().sleep(10.seconds).followedBy(effect { println("Hello") }), effect { println("Hello world") })
.fork().bind().join().bind()
}.suspended()
This code fails with a cancellation exception after one of the effects has occured. The same code without the extra fiber does not. suspended()
or not also changes nothing, unsafeRunSync will also fail.simon.vergauwen
01/20/2020, 9:27 PMThe same code without the extra fiber does not.
dispatchers().io().raceN(timer().sleep(10.seconds).followedBy(effect { println("Hello") }), effect { println("Hello world") }).bind()
works fine?simon.vergauwen
01/20/2020, 9:27 PMJannis
01/20/2020, 9:32 PMJannis
01/21/2020, 12:30 PMsimon.vergauwen
01/23/2020, 3:37 PMJannis
01/23/2020, 5:43 PMsimon.vergauwen
01/23/2020, 6:12 PM