Uses of Class
com.github.tonivade.purefun.effect.RIO

Packages that use RIO

Package	Description
com.github.tonivade.purefun.effect
com.github.tonivade.purefun.effect.util
com.github.tonivade.purefun.instances
com.github.tonivade.purefun.runtimes

Uses of RIO in com.github.tonivade.purefun.effect

Fields in com.github.tonivade.purefun.effect declared as RIO

Modifier and Type	Field	Description
private static final RIO<?,Unit>	RIO.UNIT

Methods in com.github.tonivade.purefun.effect that return RIO

Modifier and Type	Method	Description
static <R, A> RIO<R,A>	RIO.absorb(RIO<R,Either<Throwable,A>> value)
static <R, A> RIO<R,A>	RIO.access(Function1<? super R,? extends A> map)
static <R, A> RIO<R,A>	RIO.accessM(Function1<? super R,? extends Kind<RIO<R,?>,? extends A>> map)
<B> RIO<R,B>	RIO.andThen(Kind<RIO<R,?>,? extends B> next)
<B> RIO<R,B>	RIO.ap(Kind<RIO<R,?>,? extends Function1<? super A,? extends B>> apply)
static <R, A> RIO<R,A>	RIO.async(Consumer2<R,Consumer1<? super Try<? extends A>>> consumer)
static <R, A extends AutoCloseable, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use)
static <R, A, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Consumer1<? super A> release)
static <R, A, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<RIO<R,?>,Unit>> release)
static <R, A> RIO<R,A>	RIO.cancellable(Function2<R,Consumer1<? super Try<? extends A>>,RIO<R,Unit>> consumer)
static <R, A> RIO<R,A>	RIO.defer(Producer<Kind<RIO<R,?>,? extends A>> lazy)
static <R> RIO<R,R>	RIO.env()
static <R> RIO<R,Unit>	RIO.exec(CheckedRunnable task)
<B> RIO<R,B>	RIO.flatMap(Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
<B> RIO<R,B>	RIO.foldM(Function1<? super Throwable,? extends Kind<RIO<R,?>,? extends B>> mapError, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
RIO<R,Fiber<RIO<R,?>,A>>	RIO.fork()
static <R> RIO<R,Unit>	RIO.forked(Executor executor)
static <R, A> RIO<R,A>	RIO.fromEither(Producer<Either<Throwable,? extends A>> task)
static <R, A> RIO<R,A>	RIO.fromEither(Either<Throwable,? extends A> task)
static <R, A> RIO<R,A>	RIO.fromOption(Producer<Option<? extends A>> task)
static <R, A> RIO<R,A>	RIO.fromOption(Option<? extends A> task)
static <R, A> RIO<R,A>	RIO.fromTry(Producer<Try<? extends A>> task)
static <R, A> RIO<R,A>	RIO.fromTry(Try<? extends A> task)
<B> RIO<R,B>	RIO.map(Function1<? super A,? extends B> map)
static <R, A> RIO<R,A>	RIO.never()
RIO<R,A>	RIO.orElse(Kind<RIO<R,?>,? extends A> other)
static <R, A, B, C> RIO<R,C>	RIO.parMap2(Kind<RIO<R,?>,? extends A> za, Kind<RIO<R,?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <R, A, B, C> RIO<R,C>	RIO.parMap2(Executor executor, Kind<RIO<R,?>,? extends A> za, Kind<RIO<R,?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <R, A> RIO<R,A>	RIO.pure(A value)
static <R, A, B> RIO<R,Either<A,B>>	RIO.race(Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A, B> RIO<R,Either<A,B>>	RIO.race(Executor executor, Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIO.racePair(Executor executor, Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A> RIO<R,A>	RIO.raiseError(Throwable throwable)
RIO<R,A>	RIO.repeat()
RIO<R,A>	RIO.repeat(int times)
RIO<R,A>	RIO.repeat(Duration delay)
RIO<R,A>	RIO.repeat(Duration delay, int times)
RIO<R,A>	RIO.retry()
RIO<R,A>	RIO.retry(int maxRetries)
RIO<R,A>	RIO.retry(Duration delay)
RIO<R,A>	RIO.retry(Duration delay, int maxRetries)
static <R> RIO<R,Unit>	RIO.sleep(Duration delay)
static <R> RIO<R,Unit>	RIO.sleep(Executor executor, Duration delay)
static <R, A> RIO<R,A>	RIO.task(Producer<? extends A> task)
RIO<R,Tuple2<Duration,A>>	RIO.timed()
RIO<R,A>	RIO.timeout(Duration duration)
RIO<R,A>	RIO.timeout(Executor executor, Duration duration)
default RIO<R,A>	PureIO.toRIO()
static <R, A> RIO<R,A>	RIOOf.toRIO(Kind<RIO<R,?>,? extends A> value)
<R> RIO<R,A>	UIO.toRIO()
RIO<R,A>	URIO.toRIO()
<R> RIO<R,A>	Task.toURIO()
static <R, A> RIO<R,Sequence<A>>	RIO.traverse(Sequence<? extends Kind<RIO<R,?>,A>> sequence)
static <R, A> RIO<R,Sequence<A>>	RIO.traverse(Executor executor, Sequence<? extends Kind<RIO<R,?>,A>> sequence)
static <R> RIO<R,Unit>	RIO.unit()
<B> RIO<R,Tuple2<A,B>>	RIO.zip(Kind<RIO<R,?>,? extends B> other)
<B> RIO<R,A>	RIO.zipLeft(Kind<RIO<R,?>,? extends B> other)
<B> RIO<R,B>	RIO.zipRight(Kind<RIO<R,?>,? extends B> other)
<B, C> RIO<R,C>	RIO.zipWith(Kind<RIO<R,?>,? extends B> other, Function2<? super A,? super B,? extends C> mapper)

Methods in com.github.tonivade.purefun.effect that return types with arguments of type RIO

Modifier and Type	Method	Description
RIO<R,Fiber<RIO<R,?>,A>>	RIO.fork()
static <R, A, B> Function1<A,RIO<R,B>>	RIO.lift(Function1<? super A,? extends B> function)
static <R, A, B> Function1<A,RIO<R,B>>	RIO.liftEither(Function1<? super A,? extends Either<Throwable,? extends B>> function)
static <R, A, B> Function1<A,RIO<R,B>>	RIO.liftOption(Function1<? super A,? extends Option<? extends B>> function)
static <R, A, B> Function1<A,RIO<R,B>>	RIO.liftTry(Function1<? super A,? extends Try<? extends B>> function)
static <R, A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIO.racePair(Executor executor, Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIO.racePair(Executor executor, Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)

Methods in com.github.tonivade.purefun.effect with parameters of type RIO

Modifier and Type	Method	Description
static <R, A> RIO<R,A>	RIO.absorb(RIO<R,Either<Throwable,A>> value)

Method parameters in com.github.tonivade.purefun.effect with type arguments of type RIO

Modifier and Type	Method	Description
static <R, A> RIO<R,A>	RIO.accessM(Function1<? super R,? extends Kind<RIO<R,?>,? extends A>> map)
<B> RIO<R,B>	RIO.andThen(Kind<RIO<R,?>,? extends B> next)
<B> RIO<R,B>	RIO.ap(Kind<RIO<R,?>,? extends Function1<? super A,? extends B>> apply)
static <R, A extends AutoCloseable, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use)
static <R, A extends AutoCloseable, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use)
static <R, A, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Consumer1<? super A> release)
static <R, A, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Consumer1<? super A> release)
static <R, A, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<RIO<R,?>,Unit>> release)
static <R, A, B> RIO<R,B>	RIO.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<RIO<R,?>,Unit>> release)
static <R, A> RIO<R,A>	RIO.cancellable(Function2<R,Consumer1<? super Try<? extends A>>,RIO<R,Unit>> consumer)
static <R, A> RIO<R,A>	RIO.defer(Producer<Kind<RIO<R,?>,? extends A>> lazy)
<B> RIO<R,B>	RIO.flatMap(Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
<B> RIO<R,B>	RIO.foldM(Function1<? super Throwable,? extends Kind<RIO<R,?>,? extends B>> mapError, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
RIO<R,A>	RIO.orElse(Kind<RIO<R,?>,? extends A> other)
static <R, A, B, C> RIO<R,C>	RIO.parMap2(Kind<RIO<R,?>,? extends A> za, Kind<RIO<R,?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <R, A, B, C> RIO<R,C>	RIO.parMap2(Executor executor, Kind<RIO<R,?>,? extends A> za, Kind<RIO<R,?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <R, A, B> RIO<R,Either<A,B>>	RIO.race(Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A, B> RIO<R,Either<A,B>>	RIO.race(Executor executor, Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIO.racePair(Executor executor, Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R, A> RIO<R,A>	RIOOf.toRIO(Kind<RIO<R,?>,? extends A> value)
static <R, A> RIO<R,Sequence<A>>	RIO.traverse(Sequence<? extends Kind<RIO<R,?>,A>> sequence)
static <R, A> RIO<R,Sequence<A>>	RIO.traverse(Executor executor, Sequence<? extends Kind<RIO<R,?>,A>> sequence)
<B> RIO<R,Tuple2<A,B>>	RIO.zip(Kind<RIO<R,?>,? extends B> other)
<B> RIO<R,A>	RIO.zipLeft(Kind<RIO<R,?>,? extends B> other)
<B> RIO<R,B>	RIO.zipRight(Kind<RIO<R,?>,? extends B> other)
<B, C> RIO<R,C>	RIO.zipWith(Kind<RIO<R,?>,? extends B> other, Function2<? super A,? super B,? extends C> mapper)

Uses of RIO in com.github.tonivade.purefun.effect.util

Methods in com.github.tonivade.purefun.effect.util that return RIO

Modifier and Type	Method	Description
default RIO<R,Unit>	PureConsole.Service.printf(String template, Object... args)
static <R extends PureConsole> RIO<R,Unit>	PureConsole.println(String text)
default RIO<R,Unit>	PureConsole.Service.println(Object text, Object... args)
RIO<R,Unit>	PureConsole.Service.println(String text)
static <R extends PureConsole> RIO<R,String>	PureConsole.readln()
RIO<R,String>	PureConsole.Service.readln()

Uses of RIO in com.github.tonivade.purefun.instances

Methods in com.github.tonivade.purefun.instances that return RIO

Modifier and Type	Method	Description
default <A, B> RIO<R,B>	RIOApplicative.ap(Kind<RIO<R,?>,? extends A> value, Kind<RIO<R,?>,? extends Function1<? super A,? extends B>> apply)
default <A> RIO<R,A>	RIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<RIO<R,?>,Unit>> consumer)
default <A, B> RIO<R,B>	RIOBracket.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<RIO<R,?>,Unit>> release)
default <A> RIO<R,A>	RIODefer.defer(Producer<? extends Kind<RIO<R,?>,? extends A>> defer)
default <A, B> RIO<R,B>	RIOMonad.flatMap(Kind<RIO<R,?>,? extends A> value, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
default <A> RIO<R,Fiber<RIO<R,?>,A>>	RIOConcurrent.fork(Kind<RIO<R,?>,? extends A> value)
default <A> RIO<R,A>	RIOMonadError.handleErrorWith(Kind<RIO<R,?>,A> value, Function1<? super Throwable,? extends Kind<RIO<R,?>,? extends A>> handler)
default <A, B> RIO<R,B>	RIOFunctor.map(Kind<RIO<R,?>,? extends A> value, Function1<? super A,? extends B> map)
RIO<R,Unit>	RIOConsole.println(String text)
default <A> RIO<R,A>	RIOPure.pure(A value)
default <A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIOConcurrent.racePair(Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
default <A> RIO<R,A>	RIOMonadError.raiseError(Throwable error)
RIO<R,String>	RIOConsole.readln()
default RIO<R,Unit>	RIOMonadDefer.sleep(Duration duration)

Methods in com.github.tonivade.purefun.instances that return types with arguments of type RIO

Modifier and Type	Method	Description
static <R> Applicative<RIO<R,?>>	RIOInstances.applicative()
static <R> Async<RIO<R,?>>	RIOInstances.async()
static <R> Concurrent<RIO<R,?>>	RIOInstances.concurrent()
static <R> Concurrent<RIO<R,?>>	RIOInstances.concurrent(Executor executor)
static <R> Console<RIO<R,?>>	RIOInstances.console()
default <A> RIO<R,Fiber<RIO<R,?>,A>>	RIOConcurrent.fork(Kind<RIO<R,?>,? extends A> value)
static <R> Functor<RIO<R,?>>	RIOInstances.functor()
static <R> Monad<RIO<R,?>>	RIOInstances.monad()
static <R> MonadDefer<RIO<R,?>>	RIOInstances.monadDefer()
static <R> MonadThrow<RIO<R,?>>	RIOInstances.monadThrow()
static <R> PureStream.Of<RIO<R,?>>	PureStreamInstances.ofRIO()
default <A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIOConcurrent.racePair(Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
default <A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIOConcurrent.racePair(Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
static <R> Runtime<RIO<R,?>>	RIOInstances.runtime(R env)

Method parameters in com.github.tonivade.purefun.instances with type arguments of type RIO

Modifier and Type	Method	Description
default <A, B> RIO<R,B>	RIOApplicative.ap(Kind<RIO<R,?>,? extends A> value, Kind<RIO<R,?>,? extends Function1<? super A,? extends B>> apply)
default <A> RIO<R,A>	RIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<RIO<R,?>,Unit>> consumer)
default <A, B> RIO<R,B>	RIOBracket.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<RIO<R,?>,Unit>> release)
default <A, B> RIO<R,B>	RIOBracket.bracket(Kind<RIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<RIO<R,?>,Unit>> release)
default <A> RIO<R,A>	RIODefer.defer(Producer<? extends Kind<RIO<R,?>,? extends A>> defer)
default <A, B> RIO<R,B>	RIOMonad.flatMap(Kind<RIO<R,?>,? extends A> value, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
default <A, B> RIO<R,B>	RIOMonad.flatMap(Kind<RIO<R,?>,? extends A> value, Function1<? super A,? extends Kind<RIO<R,?>,? extends B>> map)
default <A> RIO<R,Fiber<RIO<R,?>,A>>	RIOConcurrent.fork(Kind<RIO<R,?>,? extends A> value)
default <A> RIO<R,A>	RIOMonadError.handleErrorWith(Kind<RIO<R,?>,A> value, Function1<? super Throwable,? extends Kind<RIO<R,?>,? extends A>> handler)
default <A> RIO<R,A>	RIOMonadError.handleErrorWith(Kind<RIO<R,?>,A> value, Function1<? super Throwable,? extends Kind<RIO<R,?>,? extends A>> handler)
default <A, B> RIO<R,B>	RIOFunctor.map(Kind<RIO<R,?>,? extends A> value, Function1<? super A,? extends B> map)
default <T> Future<Sequence<T>>	RIORuntime.parRun(Sequence<Kind<RIO<R,?>,T>> values, Executor executor)
default <T> Future<T>	RIORuntime.parRun(Kind<RIO<R,?>,T> value, Executor executor)
default <A, B> RIO<R,Either<Tuple2<A,Fiber<RIO<R,?>,B>>,Tuple2<Fiber<RIO<R,?>,A>,B>>>	RIOConcurrent.racePair(Kind<RIO<R,?>,? extends A> fa, Kind<RIO<R,?>,? extends B> fb)
default <T> Sequence<T>	RIORuntime.run(Sequence<Kind<RIO<R,?>,T>> values)
default <T> T	RIORuntime.run(Kind<RIO<R,?>,T> value)

Uses of RIO in com.github.tonivade.purefun.runtimes

Methods in com.github.tonivade.purefun.runtimes with parameters of type RIO

Modifier and Type	Method	Description
<R, T> Function1<R,Try<T>>	ConsoleExecutor.run(RIO<R,T> program)