Uses of Interface
com.github.tonivade.purefun.monad.IO

Packages that use IO

Package	Description
com.github.tonivade.purefun.instances
com.github.tonivade.purefun.monad
com.github.tonivade.purefun.runtimes

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

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

Modifier and Type	Method	Description
default <T, R> IO<R>	IOApplicative.ap(Kind<IO<?>,? extends T> value, Kind<IO<?>,? extends Function1<? super T,? extends R>> apply)
default <A> IO<A>	IOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<IO<?>,Unit>> consumer)
default <A, B> IO<B>	IOBracket.bracket(Kind<IO<?>,? extends A> acquire, Function1<? super A,? extends Kind<IO<?>,? extends B>> use, Function1<? super A,? extends Kind<IO<?>,Unit>> release)
default <A> IO<A>	IODefer.defer(Producer<? extends Kind<IO<?>,? extends A>> defer)
default <T, R> IO<R>	IOMonad.flatMap(Kind<IO<?>,? extends T> value, Function1<? super T,? extends Kind<IO<?>,? extends R>> map)
default <A> IO<Fiber<IO<?>,A>>	IOConcurrent.fork(Kind<IO<?>,? extends A> value)
default <A> IO<A>	IOMonadError.handleErrorWith(Kind<IO<?>,A> value, Function1<? super Throwable,? extends Kind<IO<?>,? extends A>> handler)
IO<Unit>	IOConsole.println(String text)
default <T> IO<T>	IOPure.pure(T value)
default <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IOConcurrent.racePair(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
default <A> IO<A>	IOMonadError.raiseError(Throwable error)
IO<String>	IOConsole.readln()
default IO<Unit>	IOMonadDefer.sleep(Duration duration)

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

Modifier and Type	Method	Description
static Applicative<IO<?>>	IOInstances.applicative()
static Applicative<IO<?>>	IOInstances.applicative(Executor executor)
static Async<IO<?>>	IOInstances.async()
static Concurrent<IO<?>>	IOInstances.concurrent()
static Concurrent<IO<?>>	IOInstances.concurrent(Executor executor)
static Console<IO<?>>	IOInstances.console()
default <A> IO<Fiber<IO<?>,A>>	IOConcurrent.fork(Kind<IO<?>,? extends A> value)
static Functor<IO<?>>	IOInstances.functor()
default <T, R> Kind<IO<?>,R>	IOFunctor.map(Kind<IO<?>,? extends T> value, Function1<? super T,? extends R> map)
static Monad<IO<?>>	IOInstances.monad()
static MonadDefer<IO<?>>	IOInstances.monadDefer()
static MonadError<IO<?>,Throwable>	IOInstances.monadError()
static MonadThrow<IO<?>>	IOInstances.monadThrow()
static PureStream.Of<IO<?>>	PureStreamInstances.ofIO()
default <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IOConcurrent.racePair(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
default <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IOConcurrent.racePair(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static Runtime<IO<?>>	IOInstances.runtime()
static Timer<IO<?>>	IOInstances.timer()

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

Modifier and Type	Method	Description
default <T, R> IO<R>	IOApplicative.ap(Kind<IO<?>,? extends T> value, Kind<IO<?>,? extends Function1<? super T,? extends R>> apply)
default <A> IO<A>	IOAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<IO<?>,Unit>> consumer)
default <A, B> IO<B>	IOBracket.bracket(Kind<IO<?>,? extends A> acquire, Function1<? super A,? extends Kind<IO<?>,? extends B>> use, Function1<? super A,? extends Kind<IO<?>,Unit>> release)
default <A, B> IO<B>	IOBracket.bracket(Kind<IO<?>,? extends A> acquire, Function1<? super A,? extends Kind<IO<?>,? extends B>> use, Function1<? super A,? extends Kind<IO<?>,Unit>> release)
default <A> IO<A>	IODefer.defer(Producer<? extends Kind<IO<?>,? extends A>> defer)
default <T, R> IO<R>	IOMonad.flatMap(Kind<IO<?>,? extends T> value, Function1<? super T,? extends Kind<IO<?>,? extends R>> map)
default <T, R> IO<R>	IOMonad.flatMap(Kind<IO<?>,? extends T> value, Function1<? super T,? extends Kind<IO<?>,? extends R>> map)
default <A> IO<Fiber<IO<?>,A>>	IOConcurrent.fork(Kind<IO<?>,? extends A> value)
default <A> IO<A>	IOMonadError.handleErrorWith(Kind<IO<?>,A> value, Function1<? super Throwable,? extends Kind<IO<?>,? extends A>> handler)
default <A> IO<A>	IOMonadError.handleErrorWith(Kind<IO<?>,A> value, Function1<? super Throwable,? extends Kind<IO<?>,? extends A>> handler)
default <T, R> Kind<IO<?>,R>	IOFunctor.map(Kind<IO<?>,? extends T> value, Function1<? super T,? extends R> map)
default <T> Future<Sequence<T>>	IORuntime.parRun(Sequence<Kind<IO<?>,T>> values, Executor executor)
default <T> Future<T>	IORuntime.parRun(Kind<IO<?>,T> value, Executor executor)
default <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IOConcurrent.racePair(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
default <T> Sequence<T>	IORuntime.run(Sequence<Kind<IO<?>,T>> values)
default <T> T	IORuntime.run(Kind<IO<?>,T> value)

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

Classes in com.github.tonivade.purefun.monad that implement IO

Modifier and Type	Class	Description
static final class	IO.Async<T>
static final class	IO.Delay<T>
static final class	IO.Failure<T>
static final class	IO.FlatMapped<T,R>
static final class	IO.Pure<T>
static final class	IO.Recover<T>
static final class	IO.Suspend<T>

Fields in com.github.tonivade.purefun.monad declared as IO

Modifier and Type	Field	Description
static final IO<Unit>	IO.UNIT

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

Modifier and Type	Field	Description
private final Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>>	IO.Async.callback
private Kind<IO<?>,Unit>	IOConnection.Cancellable.cancelToken
private final Kind<IO<?>,? extends T>	IO.FlatMapped.current
private final Kind<IO<?>,T>	IO.Recover.current
private final Producer<? extends Kind<IO<?>,? extends T>>	IO.Suspend.lazy
private final PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>>	IO.Recover.mapper
private final Function1<? super T,? extends Kind<IO<?>,? extends R>>	IO.FlatMapped.next
private final Deque<PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>>>	StackItem.recover

Methods in com.github.tonivade.purefun.monad that return IO

Modifier and Type	Method	Description
default <R> IO<R>	IO.andThen(Kind<IO<?>,? extends R> after)
default <R> IO<R>	IO.ap(Kind<IO<?>,? extends Function1<? super T,? extends R>> apply)
static <T> IO<T>	IO.async(Consumer1<Consumer1<? super Try<? extends T>>> callback)
default IO<Try<T>>	IO.attempt()
static <T extends AutoCloseable, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use)
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)
static <T, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use, Function1<? super T,? extends Kind<IO<?>,Unit>> release)
static <T> IO<T>	IO.cancellable(Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>> callback)
static <T> IO<T>	IO.delay(Duration delay, Producer<? extends T> lazy)
default IO<Either<Throwable,T>>	IO.either()
default <L, R> IO<Either<L,R>>	IO.either(Function1<? super Throwable,? extends L> mapError, Function1<? super T,? extends R> mapper)
static IO<Unit>	IO.exec(CheckedRunnable task)
default <R> IO<R>	IO.flatMap(Function1<? super T,? extends Kind<IO<?>,? extends R>> map)
default IO<Fiber<IO<?>,T>>	IO.fork()
static IO<Unit>	IO.forked()
static IO<Unit>	IO.forked(Executor executor)
static <T> IO<T>	IO.fromCompletableFuture(CompletableFuture<? extends T> promise)
static <T> IO<T>	IO.fromEither(Either<Throwable,? extends T> task)
static <T> IO<T>	IO.fromOption(Option<? extends T> task)
static <T> IO<T>	IO.fromPromise(Promise<? extends T> promise)
static <T> IO<T>	IO.fromTry(Try<? extends T> task)
IO<A>	Ref.get()
IO<A>	Ref.getAndSet(A newValue)
IO<A>	Ref.getAndUpdate(Operator1<A> update)
IO<Unit>	Ref.lazySet(A newValue)
static <A> IO<Ref<A>>	Ref.make(A value)
default <R> IO<R>	IO.map(Function1<? super T,? extends R> map)
static <A, T> IO<Function1<A,IO<T>>>	IO.memoize(Function1<A,IO<T>> function)
static <A, T> IO<Function1<A,IO<T>>>	IO.memoize(Executor executor, Function1<A,IO<T>> function)
<B> IO<B>	Ref.modify(Function1<A,Tuple2<B,A>> change)
static <T> IO<T>	IO.never()
static <A, B, C> IO<C>	IO.parMap2(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb, Function2<? super A,? super B,? extends C> mapper)
static <A, B, C> IO<C>	IO.parMap2(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb, Function2<? super A,? super B,? extends C> mapper)
static <T> IO<T>	IO.pure(T value)
static <A, B> IO<Either<A,B>>	IO.race(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Either<A,B>>	IO.race(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IO.racePair(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <T> IO<T>	IO.raiseError(Throwable error)
default IO<T>	IO.recover(Function1<? super Throwable,? extends T> mapError)
default <X extends Throwable> IO<T>	IO.recover(Class<X> type, Function1<? super X,? extends T> function)
default IO<T>	IO.recoverWith(PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>> mapper)
default <R> IO<R>	IO.redeem(Function1<? super Throwable,? extends R> mapError, Function1<? super T,? extends R> mapper)
default <R> IO<R>	IO.redeemWith(Function1<? super Throwable,? extends Kind<IO<?>,? extends R>> mapError, Function1<? super T,? extends Kind<IO<?>,? extends R>> mapper)
default IO<T>	IO.repeat()
default IO<T>	IO.repeat(int times)
private static <T> IO<T>	IO.repeat(IO<T> self, IO<Unit> pause, int times)
default IO<T>	IO.repeat(Duration delay)
default IO<T>	IO.repeat(Duration delay, int times)
default IO<T>	IO.retry()
default IO<T>	IO.retry(int maxRetries)
private static <T> IO<T>	IO.retry(IO<T> self, IO<Unit> pause, int maxRetries)
default IO<T>	IO.retry(Duration delay)
default IO<T>	IO.retry(Duration delay, int maxRetries)
static IO<Unit>	IO.sequence(Sequence<? extends Kind<IO<?>,?>> sequence)
IO<Unit>	Ref.set(A newValue)
static IO<Unit>	IO.sleep(Duration duration)
static IO<Unit>	IO.sleep(Executor executor, Duration duration)
static <T> IO<T>	IO.suspend(Producer<? extends Kind<IO<?>,? extends T>> lazy)
static <T> IO<T>	IO.task(Producer<? extends T> producer)
default IO<Tuple2<Duration,T>>	IO.timed()
default IO<T>	IO.timeout(Duration duration)
default IO<T>	IO.timeout(Executor executor, Duration duration)
static <T> IO<T>	IOOf.toIO(Kind<IO<?>,? extends T> value)
static <A> IO<Sequence<A>>	IO.traverse(Sequence<? extends Kind<IO<?>,A>> sequence)
static <A> IO<Sequence<A>>	IO.traverse(Executor executor, Sequence<? extends Kind<IO<?>,A>> sequence)
static <A, B> IO<Tuple2<A,B>>	IO.tuple(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Tuple2<A,B>>	IO.tuple(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static IO<Unit>	IO.unit()
IO<A>	Ref.updateAndGet(Operator1<A> update)

Methods in com.github.tonivade.purefun.monad that return types with arguments of type IO

Modifier and Type	Method	Description
default IO<Fiber<IO<?>,T>>	IO.fork()
static <T, R> Function1<T,IO<R>>	IO.lift(Function1<T,R> task)
static <A, B> Function1<A,IO<B>>	IO.liftEither(Function1<? super A,? extends Either<Throwable,? extends B>> function)
static <A, B> Function1<A,IO<B>>	IO.liftOption(Function1<? super A,? extends Option<? extends B>> function)
static <A, B> Function1<A,IO<B>>	IO.liftTry(Function1<? super A,? extends Try<? extends B>> function)
static <A, T> IO<Function1<A,IO<T>>>	IO.memoize(Function1<A,IO<T>> function)
static <A, T> IO<Function1<A,IO<T>>>	IO.memoize(Executor executor, Function1<A,IO<T>> function)
static <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IO.racePair(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IO.racePair(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
Option<IO<T>>	CallStack.tryHandle(Throwable error)
Option<IO<T>>	StackItem.tryHandle(Throwable error)
private static <T, U> Kind<IO<?>,T>	IO.unwrap(Kind<IO<?>,T> current, CallStack<U> stack, Function1<Kind<IO<?>,? extends T>,Kind<IO<?>,? extends U>> next)

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

Modifier and Type	Method	Description
private static <T> IO<T>	IO.repeat(IO<T> self, IO<Unit> pause, int times)
private static <T> IO<T>	IO.retry(IO<T> self, IO<Unit> pause, int maxRetries)

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

Modifier and Type	Method	Description
void	CallStack.add(PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>> mapError)
void	StackItem.add(PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>> mapError)
default <R> IO<R>	IO.andThen(Kind<IO<?>,? extends R> after)
default <R> IO<R>	IO.ap(Kind<IO<?>,? extends Function1<? super T,? extends R>> apply)
static <T extends AutoCloseable, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use)
static <T extends AutoCloseable, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use)
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)
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)
static <T, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use, Function1<? super T,? extends Kind<IO<?>,Unit>> release)
static <T, R> IO<R>	IO.bracket(Kind<IO<?>,? extends T> acquire, Function1<? super T,? extends Kind<IO<?>,? extends R>> use, Function1<? super T,? extends Kind<IO<?>,Unit>> release)
static <T> IO<T>	IO.cancellable(Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>> callback)
default <R> IO<R>	IO.flatMap(Function1<? super T,? extends Kind<IO<?>,? extends R>> map)
static <A, T> IO<Function1<A,IO<T>>>	IO.memoize(Function1<A,IO<T>> function)
static <A, T> IO<Function1<A,IO<T>>>	IO.memoize(Executor executor, Function1<A,IO<T>> function)
static <A, B, C> IO<C>	IO.parMap2(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb, Function2<? super A,? super B,? extends C> mapper)
static <A, B, C> IO<C>	IO.parMap2(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb, Function2<? super A,? super B,? extends C> mapper)
static <A, B> IO<Either<A,B>>	IO.race(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Either<A,B>>	IO.race(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Either<Tuple2<A,Fiber<IO<?>,B>>,Tuple2<Fiber<IO<?>,A>,B>>>	IO.racePair(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
default IO<T>	IO.recoverWith(PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>> mapper)
default <R> IO<R>	IO.redeemWith(Function1<? super Throwable,? extends Kind<IO<?>,? extends R>> mapError, Function1<? super T,? extends Kind<IO<?>,? extends R>> mapper)
private static <T> Promise<T>	IO.runAsync(Kind<IO<?>,T> current, IOConnection connection)
private static <T, U, V> Promise<T>	IO.runAsync(Kind<IO<?>,T> current, IOConnection connection, CallStack<T> stack, Promise<T> promise)
static IO<Unit>	IO.sequence(Sequence<? extends Kind<IO<?>,?>> sequence)
void	IOConnection.Cancellable.setCancelToken(Kind<IO<?>,Unit> cancel)
void	IOConnection.setCancelToken(Kind<IO<?>,Unit> cancel)
void	IOConnection.Uncancellable.setCancelToken(Kind<IO<?>,Unit> cancel)
static <T> IO<T>	IO.suspend(Producer<? extends Kind<IO<?>,? extends T>> lazy)
static <T> IO<T>	IOOf.toIO(Kind<IO<?>,? extends T> value)
static <A> IO<Sequence<A>>	IO.traverse(Sequence<? extends Kind<IO<?>,A>> sequence)
static <A> IO<Sequence<A>>	IO.traverse(Executor executor, Sequence<? extends Kind<IO<?>,A>> sequence)
static <A, B> IO<Tuple2<A,B>>	IO.tuple(Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
static <A, B> IO<Tuple2<A,B>>	IO.tuple(Executor executor, Kind<IO<?>,? extends A> fa, Kind<IO<?>,? extends B> fb)
private static <T, U> Kind<IO<?>,T>	IO.unwrap(Kind<IO<?>,T> current, CallStack<U> stack, Function1<Kind<IO<?>,? extends T>,Kind<IO<?>,? extends U>> next)
private static <T, U> Kind<IO<?>,T>	IO.unwrap(Kind<IO<?>,T> current, CallStack<U> stack, Function1<Kind<IO<?>,? extends T>,Kind<IO<?>,? extends U>> next)
private static <T, U> Kind<IO<?>,T>	IO.unwrap(Kind<IO<?>,T> current, CallStack<U> stack, Function1<Kind<IO<?>,? extends T>,Kind<IO<?>,? extends U>> next)

Constructors in com.github.tonivade.purefun.monad with parameters of type IO

Modifier	Constructor	Description
private	FlatMapped(IO<? extends T> current, Function1<? super T,? extends Kind<IO<?>,? extends R>> next)
private	Recover(IO<T> current, PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>> mapper)

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

Modifier	Constructor	Description
private	Async(Function1<Consumer1<? super Try<? extends T>>,Kind<IO<?>,Unit>> callback)
private	FlatMapped(IO<? extends T> current, Function1<? super T,? extends Kind<IO<?>,? extends R>> next)
private	Recover(IO<T> current, PartialFunction1<? super Throwable,? extends Kind<IO<?>,? extends T>> mapper)
private	Suspend(Producer<? extends Kind<IO<?>,? extends T>> lazy)

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

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

Modifier and Type	Method	Description
<T> T	ConsoleExecutor.run(IO<T> program)