Uses of Interface
com.github.tonivade.purefun.core.Consumer1

Packages that use Consumer1

Package	Description
com.github.tonivade.purefun.concurrent
com.github.tonivade.purefun.core
com.github.tonivade.purefun.effect
com.github.tonivade.purefun.instances
com.github.tonivade.purefun.monad
com.github.tonivade.purefun.type
com.github.tonivade.purefun.typeclasses

Uses of Consumer1 in com.github.tonivade.purefun.concurrent

Fields in com.github.tonivade.purefun.concurrent with type parameters of type Consumer1

Modifier and Type	Field	Description
private final Queue<Consumer1<? super Try<? extends T>>>	PromiseImpl.consumers

Methods in com.github.tonivade.purefun.concurrent with parameters of type Consumer1

Modifier and Type	Method	Description
static <T> Future<T>	Future.async(Consumer1<Consumer1<? super Try<? extends T>>> consumer)
static <T> Future<T>	Future.async(Executor executor, Consumer1<Consumer1<? super Try<? extends T>>> consumer)
(package private) static <T> Future<T>	FutureImpl.async(Executor executor, Consumer1<Consumer1<? super Try<? extends T>>> consumer)
static <T, R> Future<R>	Future.bracket(Future<? extends T> acquire, Function1<? super T,? extends Future<? extends R>> use, Consumer1<? super T> release)
static <T, R> Future<R>	Future.bracket(Executor executor, Future<? extends T> acquire, Function1<? super T,? extends Future<? extends R>> use, Consumer1<? super T> release)
(package private) static <T, R> Future<R>	FutureImpl.bracket(Executor executor, Future<? extends T> acquire, Function1<? super T,? extends Future<? extends R>> use, Consumer1<? super T> release)
private Option<Try<T>>	PromiseImpl.current(Consumer1<? super Try<? extends T>> consumer)
Future<T>	Future.onComplete(Consumer1<? super Try<? extends T>> callback)
Future<T>	FutureImpl.onComplete(Consumer1<? super Try<? extends T>> consumer)
Promise<T>	Promise.onComplete(Consumer1<? super Try<? extends T>> consumer)
Promise<T>	PromiseImpl.onComplete(Consumer1<? super Try<? extends T>> consumer)
Future<T>	Future.onFailure(Consumer1<? super Throwable> callback)
Future<T>	FutureImpl.onFailure(Consumer1<? super Throwable> consumer)
default Promise<T>	Promise.onFailure(Consumer1<? super Throwable> consumer)
Future<T>	Future.onSuccess(Consumer1<? super T> callback)
Future<T>	FutureImpl.onSuccess(Consumer1<? super T> consumer)
default Promise<T>	Promise.onSuccess(Consumer1<? super T> consumer)
private void	PromiseImpl.submit(Try<? extends T> value, Consumer1<? super Try<? extends T>> consumer)
default Promise<Unit>	Promise.then(Consumer1<? super T> next)

Method parameters in com.github.tonivade.purefun.concurrent with type arguments of type Consumer1

Modifier and Type	Method	Description
static <T> Future<T>	Future.async(Consumer1<Consumer1<? super Try<? extends T>>> consumer)
static <T> Future<T>	Future.async(Executor executor, Consumer1<Consumer1<? super Try<? extends T>>> consumer)
(package private) static <T> Future<T>	FutureImpl.async(Executor executor, Consumer1<Consumer1<? super Try<? extends T>>> consumer)

Uses of Consumer1 in com.github.tonivade.purefun.core

Methods in com.github.tonivade.purefun.core that return Consumer1

Modifier and Type	Method	Description
default Consumer1<A>	Consumer1.andThen(Consumer1<? super A> after)
static <A> Consumer1<A>	Consumer1.noop()
static <A> Consumer1<A>	Consumer1.of(Consumer1<? super A> reference)

Methods in com.github.tonivade.purefun.core with parameters of type Consumer1

Modifier and Type	Method	Description
default Consumer1<A>	Consumer1.andThen(Consumer1<? super A> after)
void	Tuple1.consume(Consumer1<? super A> consumer)
default void	Tuple.forEach(Consumer1<? super Object> consumer)
static <A> Consumer1<A>	Consumer1.of(Consumer1<? super A> reference)
default Runnable	CheckedRunnable.recover(Consumer1<? super Throwable> mapper)

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

Fields in com.github.tonivade.purefun.effect with type parameters of type Consumer1

Modifier and Type	Field	Description
private final Function2<R,Consumer1<? super Try<? extends Either<E,? extends A>>>,PureIO<R,?,Unit>>	PureIO.Async.callback
private final PureIO<R,E,Tuple2<A,Consumer1<? super A>>>	Managed.resource

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

Modifier and Type	Method	Description
private static <T> Consumer1<Tuple2<T,Consumer1<? super T>>>	Managed.release()
private static <X, T, R> Consumer1<X>	Managed.releaseAndThen(Tuple2<T,Consumer1<? super T>> outter, Tuple2<R,Consumer1<? super R>> inner)

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

Modifier and Type	Method	Description
private static <T> Consumer1<Tuple2<T,Consumer1<? super T>>>	Managed.release()

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

Modifier and Type	Method	Description
static <E, A> EIO<E,A>	EIO.async(Consumer1<Consumer1<? super Try<? extends Either<E,? extends A>>>> consumer)
static <A> Task<A>	Task.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
static <A> UIO<A>	UIO.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
static <E, A, B> EIO<E,B>	EIO.bracket(Kind<EIO<E,?>,? extends A> acquire, Function1<? super A,? extends Kind<EIO<E,?>,? extends B>> use, Consumer1<? super A> release)
static <R, E, A, B> PureIO<R,E,B>	PureIO.bracket(Kind<PureIO<R,E,?>,? extends A> acquire, Function1<? super A,? extends Kind<PureIO<R,E,?>,? 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 <A, B> Task<B>	Task.bracket(Kind<Task<?>,? extends A> acquire, Function1<? super A,? extends Kind<Task<?>,? extends B>> use, Consumer1<? super A> release)
static <A, B> UIO<B>	UIO.bracket(Kind<UIO<?>,? extends A> acquire, Function1<? super A,? extends Kind<UIO<?>,? extends B>> use, Consumer1<? super A> release)
static <R, A, B> URIO<R,B>	URIO.bracket(Kind<URIO<R,?>,? extends A> acquire, Function1<? super A,? extends Kind<URIO<R,?>,? extends B>> use, Consumer1<? super A> release)
static <R, E, A> Managed<R,E,A>	Managed.from(Function1<? super R,? extends A> mapper, Consumer1<? super A> release)
static <R, E, A> Managed<R,E,A>	Managed.from(PureIO<R,E,? extends A> resource, Consumer1<? super A> release)
static <R, E, A> Managed<R,E,A>	Managed.fromM(Function1<? super R,? extends PureIO<R,E,? extends A>> mapper, Consumer1<? super A> release)
default void	PureIO.provideAsync(R env, Consumer1<? super Try<? extends Either<E,A>>> callback)
default void	PureIO.provideAsync(R env, Executor executor, Consumer1<? super Try<? extends Either<E,A>>> callback)
void	EIO.safeRunAsync(Consumer1<? super Try<? extends Either<E,? extends A>>> callback)
void	RIO.safeRunAsync(R env, Consumer1<? super Try<? extends A>> callback)
void	Task.safeRunAsync(Consumer1<? super Try<? extends A>> callback)
void	UIO.safeRunAsync(Consumer1<? super Try<? extends A>> callback)
void	UIO.safeRunAsync(Executor executor, Consumer1<? super Try<? extends A>> callback)
void	URIO.safeRunAsync(R env, Consumer1<? super Try<? extends A>> callback)
default Managed<R,E,A>	PureIO.toManaged(Consumer1<? super A> release)

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

Modifier and Type	Method	Description
static <E, A> EIO<E,A>	EIO.async(Consumer1<Consumer1<? super Try<? extends Either<E,? extends A>>>> consumer)
static <R, E, A> PureIO<R,E,A>	PureIO.async(Consumer2<R,Consumer1<? super Try<? extends Either<E,? extends A>>>> consumer)
static <R, A> RIO<R,A>	RIO.async(Consumer2<R,Consumer1<? super Try<? extends A>>> consumer)
static <A> Task<A>	Task.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
static <A> UIO<A>	UIO.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
static <R, A> URIO<R,A>	URIO.async(Consumer2<R,Consumer1<? super Try<? extends A>>> consumer)
static <A> Task<A>	Task.asyncF(Function1<Consumer1<? super Try<? extends A>>,Task<Unit>> consumer)
static <E, A> EIO<E,A>	EIO.cancellable(Function1<Consumer1<? super Try<? extends Either<E,? extends A>>>,EIO<E,Unit>> consumer)
static <R, E, A> PureIO<R,E,A>	PureIO.cancellable(Function2<R,Consumer1<? super Try<? extends Either<E,? extends A>>>,PureIO<R,?,Unit>> consumer)
static <R, A> RIO<R,A>	RIO.cancellable(Function2<R,Consumer1<? super Try<? extends A>>,RIO<R,Unit>> consumer)
static <A> UIO<A>	UIO.cancellable(Function1<Consumer1<? super Try<? extends A>>,UIO<Unit>> consumer)
static <R, A> URIO<R,A>	URIO.cancellable(Function2<R,Consumer1<? super Try<? extends A>>,URIO<R,Unit>> consumer)
private static <X, T, R> Consumer1<X>	Managed.releaseAndThen(Tuple2<T,Consumer1<? super T>> outter, Tuple2<R,Consumer1<? super R>> inner)

Constructor parameters in com.github.tonivade.purefun.effect with type arguments of type Consumer1

Modifier	Constructor	Description
private	Async(Function2<R,Consumer1<? super Try<? extends Either<E,? extends A>>>,PureIO<R,?,Unit>> callback)
private	Managed(PureIO<R,E,Tuple2<A,Consumer1<? super A>>> resource)

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

Methods in com.github.tonivade.purefun.instances with parameters of type Consumer1

Modifier and Type	Method	Description
static <A> Resource<Task<?>,A>	TaskInstances.resource(Task<A> acquire, Consumer1<A> release)

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

Modifier and Type	Method	Description
default <A> EIO<Throwable,A>	EIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<EIO<Throwable,?>,Unit>> consumer)
default <A> IO<A>	IOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<IO<?>,Unit>> consumer)
default <A> PureIO<R,Throwable,A>	PureIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<PureIO<R,Throwable,?>,Unit>> consumer)
default <A> RIO<R,A>	RIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<RIO<R,?>,Unit>> consumer)
default <A> Task<A>	TaskAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<Task<?>,Unit>> consumer)
default <A> UIO<A>	UIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<UIO<?>,Unit>> consumer)
default <A> URIO<R,A>	URIOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<URIO<R,?>,Unit>> consumer)

Uses of Consumer1 in com.github.tonivade.purefun.monad

Fields in com.github.tonivade.purefun.monad with type parameters of type Consumer1

Modifier and Type	Field	Description
private final Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>>	IO.Async.callback

Methods in com.github.tonivade.purefun.monad with parameters of type Consumer1

Modifier and Type	Method	Description
static <T> IO<T>	IO.async(Consumer1<Consumer1<? super Try<? extends T>>> callback)
static <T, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use, Consumer1<? super T> release)
default void	IO.safeRunAsync(Consumer1<? super Try<? extends T>> callback)
default void	IO.safeRunAsync(Executor executor, Consumer1<? super Try<? extends T>> callback)

Method parameters in com.github.tonivade.purefun.monad with type arguments of type Consumer1

Modifier and Type	Method	Description
static <T> IO<T>	IO.async(Consumer1<Consumer1<? super Try<? extends T>>> callback)
static <T> IO<T>	IO.cancellable(Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>> callback)

Constructor parameters in com.github.tonivade.purefun.monad with type arguments of type Consumer1

Modifier	Constructor	Description
private	Async(Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>> callback)

Uses of Consumer1 in com.github.tonivade.purefun.type

Methods in com.github.tonivade.purefun.type with parameters of type Consumer1

Modifier and Type	Method	Description
default Option<T>	Option.ifPresent(Consumer1<? super T> consumer)
default Try<T>	Try.onFailure(Consumer1<? super Throwable> consumer)
default Try<T>	Try.onSuccess(Consumer1<? super T> consumer)

Uses of Consumer1 in com.github.tonivade.purefun.typeclasses

Fields in com.github.tonivade.purefun.typeclasses with type parameters of type Consumer1

Modifier and Type	Field	Description
private final Kind<F,Tuple2<T,Consumer1<? super T>>>	Resource.resource

Methods in com.github.tonivade.purefun.typeclasses that return Consumer1

Modifier and Type	Method	Description
private static <T> Consumer1<Tuple2<T,Consumer1<? super T>>>	Resource.release()

Methods in com.github.tonivade.purefun.typeclasses that return types with arguments of type Consumer1

Modifier and Type	Method	Description
private static <T> Consumer1<Tuple2<T,Consumer1<? super T>>>	Resource.release()

Methods in com.github.tonivade.purefun.typeclasses with parameters of type Consumer1

Modifier and Type	Method	Description
default <A> Kind<F,A>	Async.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
default <A, B> Kind<F,B>	Bracket.bracket(Kind<F,? extends A> acquire, Function1<? super A,? extends Kind<F,? extends B>> use, Consumer1<? super A> release)
void	AbstractApply.end(Consumer1<? super Kind<F,A>> consumer)
void	AbstractFlatMap.end(Consumer1<? super Kind<F,B>> consumer)
default void	TupleK.forEach(Consumer1<? super Kind<F,?>> consumer)
static <F extends Kind<F, ?>, T> Resource<F,T>	Resource.from(MonadDefer<F> monad, Kind<F,? extends T> acquire, Consumer1<? super T> release)
default <A> Resource<F,A>	MonadDefer.resource(Kind<F,A> acquire, Consumer1<A> release)

Method parameters in com.github.tonivade.purefun.typeclasses with type arguments of type Consumer1

Modifier and Type	Method	Description
default <A> Kind<F,A>	Async.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
<A> Kind<F,A>	Async.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<F,Unit>> consumer)
default <A> Kind<F,A>	Concurrent.cancellable(Function1<Consumer1<? super Try<? extends A>>,Kind<F,Unit>> callback)
private static <T, R> void	Resource.releaseAndThen(Tuple2<T,Consumer1<? super T>> outter, Tuple2<R,Consumer1<? super R>> inner)

Constructor parameters in com.github.tonivade.purefun.typeclasses with type arguments of type Consumer1

Modifier	Constructor	Description
(package private)	Resource(MonadDefer<F> monad, Kind<F,Tuple2<T,Consumer1<? super T>>> resource)