Package com.github.tonivade.purefun.effect

Class URIO<R,A>

java.lang.Object

com.github.tonivade.purefun.effect.URIO<R,A>

All Implemented Interfaces:

Applicable<URIO<R,?>,A>, Bindable<URIO<R,?>,A>, Effect<URIO<R,?>,A>, Mappable<URIO<R,?>,A>, Recoverable, URIOOf<R,A>, Kind<URIO<R,?>,A>

public final class URIO<R,A>
extends Object
implements URIOOf<R,A>, Effect<URIO<R,?>,A>, Recoverable

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.tonivade.purefun.core.Applicable

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

Field Summary

Fields

Modifier and Type	Field	Description
private final PureIO<R,Void,A>	instance
private static final URIO<?,Unit>	UNIT

Constructor Summary

Constructors

Constructor	Description
URIO(PureIO<R,Void,A> value)

Method Summary

Modifier and Type	Method	Description
static <R, A> URIO<R,A>	access(Function1<? super R,? extends A> map)
static <R, A> URIO<R,A>	accessM(Function1<? super R,? extends Kind<URIO<R,?>,? extends A>> map)
<B> URIO<R,B>	andThen(Kind<URIO<R,?>,? extends B> next)
<B> URIO<R,B>	ap(Kind<URIO<R,?>,? extends Function1<? super A,? extends B>> apply)
static <R, A> URIO<R,A>	async(Consumer2<R,Consumer1<? super Try<? extends A>>> consumer)
static <R, A extends AutoCloseable, B> URIO<R,B>	bracket(Kind<URIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use)
static <R, A, B> URIO<R,B>	bracket(Kind<URIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use, Consumer1<? super A> release)
static <R, A, B> URIO<R,B>	bracket(Kind<URIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use, Function1<? super A,? extends Kind<URIO<R,?>,Unit>> release)
static <R, A> URIO<R,A>	cancellable(Function2<R,Consumer1<? super Try<? extends A>>,URIO<R,Unit>> consumer)
static <R, A> URIO<R,A>	defer(Producer<Kind<URIO<R,?>,? extends A>> lazy)
static <R> URIO<R,R>	env()
static <R> URIO<R,Unit>	exec(CheckedRunnable task)
<B> URIO<R,B>	flatMap(Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> map)
private static <R, A> URIO<R,A>	fold(PureIO<R,Throwable,A> zio)
URIO<R,Fiber<URIO<R,?>,A>>	fork()
static <R> URIO<R,Unit>	forked(Executor executor)
static <R, T> URIO<R,T>	fromEither(Either<Throwable,? extends T> task)
static <R, T> URIO<R,T>	fromOption(Option<? extends T> task)
static <R, T> URIO<R,T>	fromTry(Try<? extends T> task)
static <R, A, B> Function1<A,URIO<R,B>>	lift(Function1<? super A,? extends B> function)
static <R, A, B> Function1<A,URIO<R,B>>	liftEither(Function1<? super A,? extends Either<Throwable,? extends B>> function)
static <R, A, B> Function1<A,URIO<R,B>>	liftOption(Function1<? super A,? extends Option<? extends B>> function)
static <R, A, B> Function1<A,URIO<R,B>>	liftTry(Function1<? super A,? extends Try<? extends B>> function)
<B> URIO<R,B>	map(Function1<? super A,? extends B> map)
static <R, A> URIO<R,A>	never()
static <R, A, B, C> URIO<R,C>	parMap2(Kind<URIO<R,?>,? extends A> za, Kind<URIO<R,?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <R, A, B, C> URIO<R,C>	parMap2(Executor executor, Kind<URIO<R,?>,? extends A> za, Kind<URIO<R,?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <R, A> URIO<R,A>	pure(A value)
static <R, A, B> URIO<R,Either<A,B>>	race(Kind<URIO<R,?>,? extends A> fa, Kind<URIO<R,?>,? extends B> fb)
static <R, A, B> URIO<R,Either<A,B>>	race(Executor executor, Kind<URIO<R,?>,? extends A> fa, Kind<URIO<R,?>,? extends B> fb)
static <R, A, B> URIO<R,Either<Tuple2<A,Fiber<URIO<R,?>,B>>,Tuple2<Fiber<URIO<R,?>,A>,B>>>	racePair(Executor executor, Kind<URIO<R,?>,? extends A> fa, Kind<URIO<R,?>,? extends B> fb)
static <R, A> URIO<R,A>	raiseError(Throwable throwable)
URIO<R,A>	recover(Function1<? super Throwable,? extends A> mapError)
<X extends Throwable> URIO<R,A>	recoverWith(Class<X> type, Function1<? super X,? extends A> function)
<B> URIO<R,B>	redeem(Function1<? super Throwable,? extends B> mapError, Function1<? super A,? extends B> map)
<B> URIO<R,B>	redeemWith(Function1<? super Throwable,? extends Kind<URIO<R,?>,? extends B>> mapError, Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> map)
URIO<R,A>	repeat()
URIO<R,A>	repeat(int times)
private static <R, A> URIO<R,A>	repeat(URIO<R,A> self, URIO<R,Unit> pause, int times)
URIO<R,A>	repeat(Duration delay)
URIO<R,A>	repeat(Duration delay, int times)
URIO<R,A>	retry()
URIO<R,A>	retry(int maxRetries)
private static <R, A> URIO<R,A>	retry(URIO<R,A> self, URIO<R,Unit> pause, int maxRetries)
URIO<R,A>	retry(Duration delay)
URIO<R,A>	retry(Duration delay, int maxRetries)
Future<A>	runAsync(R env)
Future<A>	runAsync(R env, Executor executor)
void	safeRunAsync(R env, Consumer1<? super Try<? extends A>> callback)
Try<A>	safeRunSync(R env)
static <R> URIO<R,Unit>	sleep(Duration delay)
static <R> URIO<R,Unit>	sleep(Executor executor, Duration delay)
static <R, A> URIO<R,A>	task(Producer<? extends A> task)
URIO<R,Tuple2<Duration,A>>	timed()
URIO<R,A>	timeout(Duration duration)
URIO<R,A>	timeout(Executor executor, Duration duration)
<E> EIO<E,A>	toEIO()
<E> PureIO<R,E,A>	toPureIO()
RIO<R,A>	toRIO()
static <R, A> URIO<R,Sequence<A>>	traverse(Sequence<? extends Kind<URIO<R,?>,A>> sequence)
static <R, A> URIO<R,Sequence<A>>	traverse(Executor executor, Sequence<? extends Kind<URIO<R,?>,A>> sequence)
static <R> URIO<R,Unit>	unit()
A	unsafeRunSync(R env)
<B> URIO<R,Tuple2<A,B>>	zip(Kind<URIO<R,?>,? extends B> other)
<B> URIO<R,A>	zipLeft(Kind<URIO<R,?>,? extends B> other)
<B> URIO<R,B>	zipRight(Kind<URIO<R,?>,? extends B> other)
<B, C> URIO<R,C>	zipWith(Kind<URIO<R,?>,? extends B> other, Function2<? super A,? super B,? extends C> mapper)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.github.tonivade.purefun.Kind

fix, kind

Methods inherited from interface com.github.tonivade.purefun.core.Recoverable

sneakyThrow

Field Details

UNIT

private static final URIO<?,Unit> UNIT

instance

private final PureIO<R,Void,A> instance

Constructor Details

URIO

URIO(PureIO<R,Void,A> value)

Method Details

unsafeRunSync

public A unsafeRunSync(R env)

safeRunSync

public Try<A> safeRunSync(R env)

toPureIO

public <E> PureIO<R,E,A> toPureIO()

toEIO

public <E> EIO<E,A> toEIO()

toRIO

public RIO<R,A> toRIO()

runAsync

public Future<A> runAsync(R env)

runAsync

public Future<A> runAsync(R env,
 Executor executor)

safeRunAsync

public void safeRunAsync(R env,
 Consumer1<? super Try<? extends A>> callback)

map

public <B> URIO<R,B> map(Function1<? super A,? extends B> map)

Specified by:

map in interface Applicable<R,A>

Specified by:

map in interface Bindable<R,A>

Specified by:

map in interface Effect<R,A>

Specified by:

map in interface Mappable<R,A>

flatMap

public <B> URIO<R,B> flatMap(Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> map)

Specified by:

flatMap in interface Bindable<R,A>

Specified by:

flatMap in interface Effect<R,A>

andThen

public <B> URIO<R,B> andThen(Kind<URIO<R,?>,? extends B> next)

Specified by:

andThen in interface Bindable<R,A>

Specified by:

andThen in interface Effect<R,A>

ap

public <B> URIO<R,B> ap(Kind<URIO<R,?>,? extends Function1<? super A,? extends B>> apply)

Specified by:

ap in interface Applicable<R,A>

Specified by:

ap in interface Effect<R,A>

recover

public URIO<R,A> recover(Function1<? super Throwable,? extends A> mapError)

recoverWith

public <X extends Throwable> URIO<R,A> recoverWith(Class<X> type,
 Function1<? super X,? extends A> function)

redeem

public <B> URIO<R,B> redeem(Function1<? super Throwable,? extends B> mapError,
 Function1<? super A,? extends B> map)

redeemWith

public <B> URIO<R,B> redeemWith(Function1<? super Throwable,? extends Kind<URIO<R,?>,? extends B>> mapError,
 Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> map)

zip

public <B> URIO<R,Tuple2<A,B>> zip(Kind<URIO<R,?>,? extends B> other)

Specified by:

zip in interface Applicable<R,A>

Specified by:

zip in interface Effect<R,A>

zipLeft

public <B> URIO<R,A> zipLeft(Kind<URIO<R,?>,? extends B> other)

Specified by:

zipLeft in interface Applicable<R,A>

Specified by:

zipLeft in interface Effect<R,A>

zipRight

public <B> URIO<R,B> zipRight(Kind<URIO<R,?>,? extends B> other)

Specified by:

zipRight in interface Applicable<R,A>

Specified by:

zipRight in interface Effect<R,A>

zipWith

public <B,
C> URIO<R,C> zipWith(Kind<URIO<R,?>,? extends B> other,
 Function2<? super A,? super B,? extends C> mapper)

Specified by:

zipWith in interface Applicable<R,A>

Specified by:

zipWith in interface Effect<R,A>

fork

public URIO<R,Fiber<URIO<R,?>,A>> fork()

timeout

public URIO<R,A> timeout(Duration duration)

Specified by:

timeout in interface Effect<R,A>

timeout

public URIO<R,A> timeout(Executor executor,
 Duration duration)

repeat

public URIO<R,A> repeat()

Specified by:

repeat in interface Effect<R,A>

repeat

public URIO<R,A> repeat(int times)

Specified by:

repeat in interface Effect<R,A>

repeat

public URIO<R,A> repeat(Duration delay)

Specified by:

repeat in interface Effect<R,A>

repeat

public URIO<R,A> repeat(Duration delay,
 int times)

Specified by:

repeat in interface Effect<R,A>

retry

public URIO<R,A> retry()

Specified by:

retry in interface Effect<R,A>

retry

public URIO<R,A> retry(int maxRetries)

Specified by:

retry in interface Effect<R,A>

retry

public URIO<R,A> retry(Duration delay)

Specified by:

retry in interface Effect<R,A>

retry

public URIO<R,A> retry(Duration delay,
 int maxRetries)

Specified by:

retry in interface Effect<R,A>

timed

public URIO<R,Tuple2<Duration,A>> timed()

Specified by:

timed in interface Effect<R,A>

forked

public static <R> URIO<R,Unit> forked(Executor executor)

accessM

public static <R,
A> URIO<R,A> accessM(Function1<? super R,? extends Kind<URIO<R,?>,? extends A>> map)

access

public static <R,
A> URIO<R,A> access(Function1<? super R,? extends A> map)

env

public static <R> URIO<R,R> env()

parMap2

public static <R,
A,
B,
C> URIO<R,C> parMap2(Kind<URIO<R,?>,? extends A> za,
 Kind<URIO<R,?>,? extends B> zb,
 Function2<? super A,? super B,? extends C> mapper)

parMap2

public static <R,
A,
B,
C> URIO<R,C> parMap2(Executor executor,
 Kind<URIO<R,?>,? extends A> za,
 Kind<URIO<R,?>,? extends B> zb,
 Function2<? super A,? super B,? extends C> mapper)

race

public static <R,
A,
B> URIO<R,Either<A,B>> race(Kind<URIO<R,?>,? extends A> fa,
 Kind<URIO<R,?>,? extends B> fb)

race

public static <R,
A,
B> URIO<R,Either<A,B>> race(Executor executor,
 Kind<URIO<R,?>,? extends A> fa,
 Kind<URIO<R,?>,? extends B> fb)

racePair

public static <R,
A,
B>
URIO<R,Either<Tuple2<A,Fiber<URIO<R,?>,B>>,Tuple2<Fiber<URIO<R,?>,A>,B>>> racePair(Executor executor,
 Kind<URIO<R,?>,? extends A> fa,
 Kind<URIO<R,?>,? extends B> fb)

lift

public static <R,
A,
B> Function1<A,URIO<R,B>> lift(Function1<? super A,? extends B> function)

liftOption

public static <R,
A,
B> Function1<A,URIO<R,B>> liftOption(Function1<? super A,? extends Option<? extends B>> function)

liftTry

public static <R,
A,
B> Function1<A,URIO<R,B>> liftTry(Function1<? super A,? extends Try<? extends B>> function)

liftEither

public static <R,
A,
B> Function1<A,URIO<R,B>> liftEither(Function1<? super A,? extends Either<Throwable,? extends B>> function)

sleep

public static <R> URIO<R,Unit> sleep(Duration delay)

sleep

public static <R> URIO<R,Unit> sleep(Executor executor,
 Duration delay)

exec

public static <R> URIO<R,Unit> exec(CheckedRunnable task)

pure

public static <R,
A> URIO<R,A> pure(A value)

raiseError

public static <R,
A> URIO<R,A> raiseError(Throwable throwable)

defer

public static <R,
A> URIO<R,A> defer(Producer<Kind<URIO<R,?>,? extends A>> lazy)

task

public static <R,
A> URIO<R,A> task(Producer<? extends A> task)

fromOption

public static <R,
T> URIO<R,T> fromOption(Option<? extends T> task)

fromTry

public static <R,
T> URIO<R,T> fromTry(Try<? extends T> task)

fromEither

public static <R,
T> URIO<R,T> fromEither(Either<Throwable,? extends T> task)

never

public static <R,
A> URIO<R,A> never()

async

public static <R,
A> URIO<R,A> async(Consumer2<R,Consumer1<? super Try<? extends A>>> consumer)

cancellable

public static <R,
A> URIO<R,A> cancellable(Function2<R,Consumer1<? super Try<? extends A>>,URIO<R,Unit>> consumer)

traverse

public static <R,
A> URIO<R,Sequence<A>> traverse(Sequence<? extends Kind<URIO<R,?>,A>> sequence)

traverse

public static <R,
A> URIO<R,Sequence<A>> traverse(Executor executor,
 Sequence<? extends Kind<URIO<R,?>,A>> sequence)

bracket

public static <R,
A extends AutoCloseable,
B>
URIO<R,B> bracket(Kind<URIO<R,?>,? extends A> acquire,
 Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use)

bracket

public static <R,
A,
B> URIO<R,B> bracket(Kind<URIO<R,?>,? extends A> acquire,
 Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use,
 Consumer1<? super A> release)

bracket

public static <R,
A,
B> URIO<R,B> bracket(Kind<URIO<R,?>,? extends A> acquire,
 Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use,
 Function1<? super A,? extends Kind<URIO<R,?>,Unit>> release)

unit

public static <R> URIO<R,Unit> unit()

fold

private static <R,
A> URIO<R,A> fold(PureIO<R,Throwable,A> zio)

repeat

private static <R,
A> URIO<R,A> repeat(URIO<R,A> self,
 URIO<R,Unit> pause,
 int times)

retry

private static <R,
A> URIO<R,A> retry(URIO<R,A> self,
 URIO<R,Unit> pause,
 int maxRetries)