arrow-effects-extensions / arrow.effects.extensions / IOConcurrentEffect

IOConcurrentEffect

interface IOConcurrentEffect : ConcurrentEffect<ForIO>, IOEffect, IOConcurrent

Functions

runAsyncCancellable open fun <A> IOOf<A>.runAsyncCancellable(cb: (Either<Throwable, A>) -> IOOf<Unit>): IO<Disposable>

Inherited Functions

async open fun <A> async(fa: ConnectedProc<ForIO, A>): IO<A>
asyncF open fun <A> asyncF(fa: ConnectedProcF<ForIO, A>): IO<A>
racePair open fun <A, B> CoroutineContext.racePair(fa: Kind<ForIO, A>, fb: Kind<ForIO, B>): IO<RacePair<ForIO, A, B>>
raceTriple open fun <A, B, C> CoroutineContext.raceTriple(fa: Kind<ForIO, A>, fb: Kind<ForIO, B>, fc: Kind<ForIO, C>): IO<RaceTriple<ForIO, A, B, C>>
startFiber open fun <A> CoroutineContext.startFiber(kind: IOOf<A>): IO<Fiber<ForIO, A>>

Extension Functions

catch fun <A> ApplicativeError<ForIO, Throwable>.catch(arg1: () -> A): IO<A>
just fun <A> A.just(): IO<A>
just fun <F, E, A> A.just(BR: Bracket<F, E>): Resource<F, E, A>