Marcin Gryszko
06/25/2019, 5:05 AMIO effect? I checked quickly Cats IO and there is a timeout combinator.
My use case is quite simple: I have two concurrent tasks whose results are combined with parMapN. I'd like to specify the timeout of the entire operation:
val op1: IO<Any> = ...
val op2: IO<Any> = ...
fx {
!NonBlocking.parMapN(op1, op2, ::Pair)
}