Package com.github.tonivade.purefun.instances

Interface PureIOConcurrent<R>

All Superinterfaces:

Applicative<PureIO<R,Throwable,?>>, ApplicativeError<PureIO<R,Throwable,?>,Throwable>, Async<PureIO<R,Throwable,?>>, Bracket<PureIO<R,Throwable,?>,Throwable>, Concurrent<PureIO<R,Throwable,?>>, Defer<PureIO<R,Throwable,?>>, Functor<PureIO<R,Throwable,?>>, Invariant<PureIO<R,Throwable,?>>, Monad<PureIO<R,Throwable,?>>, MonadDefer<PureIO<R,Throwable,?>>, MonadError<PureIO<R,Throwable,?>,Throwable>, MonadThrow<PureIO<R,Throwable,?>>, PureIOAsync<R>, PureIOBracket<R,Throwable>, PureIODefer<R,Throwable>, PureIOMonad<R,Throwable>, PureIOMonadDefer<R>, PureIOMonadError<R,Throwable>, PureIOPure<R,Throwable>, Selective<PureIO<R,Throwable,?>>, Timer<PureIO<R,Throwable,?>>

interface PureIOConcurrent<R>
extends Concurrent<PureIO<R,Throwable,?>>, PureIOAsync<R>

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.tonivade.purefun.typeclasses.Applicative

Applicative.Map2<F extends Kind<F,?>,A,B>, Applicative.Map3<F extends Kind<F,?>,A,B,C>, Applicative.Map4<F extends Kind<F,?>,A,B,C,D>, Applicative.Map5<F extends Kind<F,?>,A,B,C,D,E>

Field Summary

Fields inherited from interface com.github.tonivade.purefun.instances.PureIOAsync

INSTANCE

Method Summary

Modifier and Type	Method	Description
Executor	executor()
default <A> PureIO<R,Throwable,Fiber<PureIO<R,Throwable,?>,A>>	fork(Kind<PureIO<R,Throwable,?>,? extends A> value)
static <R> PureIOConcurrent<R>	instance(Executor executor)
default <A, B> PureIO<R,Throwable,Either<Tuple2<A,Fiber<PureIO<R,Throwable,?>,B>>,Tuple2<Fiber<PureIO<R,Throwable,?>,A>,B>>>	racePair(Kind<PureIO<R,Throwable,?>,? extends A> fa, Kind<PureIO<R,Throwable,?>,? extends B> fb)

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Applicative

first, last, mapN, mapN, mapN, mapN, mapN, mapN, mapN, mapN, tuple, tuple, tuple, tuple

Methods inherited from interface com.github.tonivade.purefun.typeclasses.ApplicativeError

attempt, fromEither, handleError, recover, recoverWith

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Async

async

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Bracket

bracket, bracket

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Concurrent

background, cancellable, race

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Functor

imap, lift

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Monad

andThen, ap, flatten, map, select, tailRecM, use

Methods inherited from interface com.github.tonivade.purefun.typeclasses.MonadDefer

currentNanos, exec, later, ref, resource, resource, scheduleOf, summarized, timed

Methods inherited from interface com.github.tonivade.purefun.typeclasses.MonadError

ensure, repeat, repeatOrElse, repeatOrElseEither, retry, retryOrElse, retryOrElseEither

Methods inherited from interface com.github.tonivade.purefun.typeclasses.MonadThrow

fromTry

Methods inherited from interface com.github.tonivade.purefun.instances.PureIOAsync

asyncF

Methods inherited from interface com.github.tonivade.purefun.instances.PureIOBracket

bracket

Methods inherited from interface com.github.tonivade.purefun.instances.PureIODefer

defer

Methods inherited from interface com.github.tonivade.purefun.instances.PureIOMonad

flatMap

Methods inherited from interface com.github.tonivade.purefun.instances.PureIOMonadDefer

sleep

Methods inherited from interface com.github.tonivade.purefun.instances.PureIOMonadError

handleErrorWith, raiseError

Methods inherited from interface com.github.tonivade.purefun.instances.PureIOPure

pure

Methods inherited from interface com.github.tonivade.purefun.typeclasses.Selective

allS, allS, andS, anyS, anyS, branch, ifS, orS, whenS

Method Details

instance

static <R> PureIOConcurrent<R> instance(Executor executor)

executor

Executor executor()

racePair

default <A,
B>
PureIO<R,Throwable,Either<Tuple2<A,Fiber<PureIO<R,Throwable,?>,B>>,Tuple2<Fiber<PureIO<R,Throwable,?>,A>,B>>> racePair(Kind<PureIO<R,Throwable,?>,? extends A> fa,
 Kind<PureIO<R,Throwable,?>,? extends B> fb)

Specified by:

racePair in interface Concurrent<R>

fork

default <A>
PureIO<R,Throwable,Fiber<PureIO<R,Throwable,?>,A>> fork(Kind<PureIO<R,Throwable,?>,? extends A> value)

Specified by:

fork in interface Concurrent<R>