arrow-effects-extensions / arrow.effects.extensions / IOConcurrent

IOConcurrent

interface IOConcurrent : Concurrent<ForIO>, IOAsync

Functions

async	open fun <A> async(fa: ConnectedProc<ForIO, A>): IO<A> open fun <A> async(fa: Proc<A>): IO<A>
asyncF	open fun <A> asyncF(fa: ConnectedProcF<ForIO, A>): IO<A> open fun <A> asyncF(k: ProcF<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>

Inheritors

IOConcurrentEffect

interface IOConcurrentEffect : ConcurrentEffect<ForIO>, IOEffect, IOConcurrent