Package com.github.tonivade.purefun.effect

Class Managed<R,E,A>

java.lang.Object

com.github.tonivade.purefun.effect.Managed<R,E,A>

All Implemented Interfaces:

ManagedOf<R,E,A>, Kind<Managed<R,E,?>,A>

public final class Managed<R,E,A>
extends Object
implements ManagedOf<R,E,A>

Field Summary

Fields

Modifier and Type	Field	Description
private final PureIO<R,E,Tuple2<A,Consumer1<? super A>>>	resource

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Managed(PureIO<R,E,Tuple2<A,Consumer1<? super A>>> resource)

Method Summary

Modifier and Type	Method	Description
<B> Managed<R,E,B>	andThen(Kind<Managed<A,E,?>,B> other)
<B> Managed<R,E,Tuple2<A,B>>	combine(Managed<R,E,B> other)
<B> Managed<R,E,Either<A,B>>	either(Managed<R,E,B> other)
<B> Managed<R,E,B>	flatMap(Function1<? super A,? extends Kind<Managed<R,E,?>,? extends B>> mapper)
<F> Managed<R,F,A>	flatMapError(Function1<? super E,? extends Kind<Managed<R,F,?>,? extends A>> mapper)
<B> Managed<R,Void,B>	fold(Function1<? super E,? extends B> mapError, Function1<? super A,? extends B> mapper)
<F, B> Managed<R,F,B>	foldM(Function1<? super E,? extends Kind<Managed<R,F,?>,? extends B>> mapError, Function1<? super A,? extends Kind<Managed<R,F,?>,? extends B>> mapper)
static <R, E, A extends AutoCloseable> Managed<R,E,A>	from(Function1<? super R,? extends A> mapper)
static <R, E, A> Managed<R,E,A>	from(Function1<? super R,? extends A> mapper, Consumer1<? super A> release)
static <R, E, A extends AutoCloseable> Managed<R,E,A>	from(PureIO<R,E,? extends A> resource)
static <R, E, A> Managed<R,E,A>	from(PureIO<R,E,? extends A> resource, Consumer1<? super A> release)
static <R, E, A extends AutoCloseable> Managed<R,E,A>	fromM(Function1<? super R,? extends PureIO<R,E,? extends A>> mapper)
static <R, E, A> Managed<R,E,A>	fromM(Function1<? super R,? extends PureIO<R,E,? extends A>> mapper, Consumer1<? super A> release)
<B> Managed<R,E,B>	map(Function1<? super A,? extends B> mapper)
<F> Managed<R,F,A>	mapError(Function1<? super E,? extends F> mapper)
Managed<R,E,A>	orElse(Managed<R,E,? extends A> other)
static <R, E, A> Managed<R,E,A>	pure(A resource)
static <R, E, A> Managed<R,E,A>	pure(PureIO<R,E,? extends A> resource)
Managed<R,Void,A>	recover(Function1<? super E,? extends A> mapError)
private static <T> Consumer1<Tuple2<T,Consumer1<? super T>>>	release()
private static <X, T, R> Consumer1<X>	releaseAndThen(Tuple2<T,Consumer1<? super T>> outter, Tuple2<R,Consumer1<? super R>> inner)
Managed<R,E,A>	retry()
Managed<R,E,A>	retry(int maxRetries)
Managed<R,E,A>	retry(Duration delay)
Managed<R,E,A>	retry(Duration delay, int maxRetries)
Managed<R,E,Tuple2<Duration,A>>	timed()
<B> PureIO<R,E,B>	use(Function1<? super A,? extends PureIO<R,E,? extends B>> use)

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

Field Details

resource

private final PureIO<R,E,Tuple2<A,Consumer1<? super A>>> resource

Constructor Details

Managed

private Managed(PureIO<R,E,Tuple2<A,Consumer1<? super A>>> resource)

Method Details

map

public <B> Managed<R,E,B> map(Function1<? super A,? extends B> mapper)

mapError

public <F> Managed<R,F,A> mapError(Function1<? super E,? extends F> mapper)

flatMap

public <B> Managed<R,E,B> flatMap(Function1<? super A,? extends Kind<Managed<R,E,?>,? extends B>> mapper)

flatMapError

public <F> Managed<R,F,A> flatMapError(Function1<? super E,? extends Kind<Managed<R,F,?>,? extends A>> mapper)

andThen

public <B> Managed<R,E,B> andThen(Kind<Managed<A,E,?>,B> other)

use

public <B> PureIO<R,E,B> use(Function1<? super A,? extends PureIO<R,E,? extends B>> use)

fold

public <B> Managed<R,Void,B> fold(Function1<? super E,? extends B> mapError,
 Function1<? super A,? extends B> mapper)

recover

public Managed<R,Void,A> recover(Function1<? super E,? extends A> mapError)

orElse

public Managed<R,E,A> orElse(Managed<R,E,? extends A> other)

foldM

public <F,
B> Managed<R,F,B> foldM(Function1<? super E,? extends Kind<Managed<R,F,?>,? extends B>> mapError,
 Function1<? super A,? extends Kind<Managed<R,F,?>,? extends B>> mapper)

combine

public <B> Managed<R,E,Tuple2<A,B>> combine(Managed<R,E,B> other)

either

public <B> Managed<R,E,Either<A,B>> either(Managed<R,E,B> other)

retry

public Managed<R,E,A> retry()

retry

public Managed<R,E,A> retry(int maxRetries)

retry

public Managed<R,E,A> retry(Duration delay)

retry

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

timed

public Managed<R,E,Tuple2<Duration,A>> timed()

pure

public static <R,
E,
A> Managed<R,E,A> pure(A resource)

pure

public static <R,
E,
A> Managed<R,E,A> pure(PureIO<R,E,? extends A> resource)

from

public static <R,
E,
A extends AutoCloseable>
Managed<R,E,A> from(PureIO<R,E,? extends A> resource)

from

public static <R,
E,
A> Managed<R,E,A> from(PureIO<R,E,? extends A> resource,
 Consumer1<? super A> release)

from

public static <R,
E,
A extends AutoCloseable>
Managed<R,E,A> from(Function1<? super R,? extends A> mapper)

from

public static <R,
E,
A> Managed<R,E,A> from(Function1<? super R,? extends A> mapper,
 Consumer1<? super A> release)

fromM

public static <R,
E,
A extends AutoCloseable>
Managed<R,E,A> fromM(Function1<? super R,? extends PureIO<R,E,? extends A>> mapper)

fromM

public static <R,
E,
A> Managed<R,E,A> fromM(Function1<? super R,? extends PureIO<R,E,? extends A>> mapper,
 Consumer1<? super A> release)

releaseAndThen

private static <X,
T,
R> Consumer1<X> releaseAndThen(Tuple2<T,Consumer1<? super T>> outter,
 Tuple2<R,Consumer1<? super R>> inner)

release

private static <T>
Consumer1<Tuple2<T,Consumer1<? super T>>> release()