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

Packages that use Task

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

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

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

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

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

Modifier and Type	Method	Description
static <A> Task<A>	Task.absorb(Task<Either<Throwable,A>> value)
<B> Task<B>	Task.andThen(Kind<Task<?>,? extends B> next)
<B> Task<B>	Task.ap(Kind<Task<?>,? extends Function1<? super A,? extends B>> apply)
static <A> Task<A>	Task.async(Consumer1<Consumer1<? super Try<? extends A>>> consumer)
static <A> Task<A>	Task.asyncF(Function1<Consumer1<? super Try<? extends A>>,Task<Unit>> consumer)
static <A extends AutoCloseable, B> Task<B>	Task.bracket(Kind<Task<?>,? extends A> acquire, Function1<? super A,? extends Kind<Task<?>,? extends B>> use)
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> Task<B>	Task.bracket(Kind<Task<?>,? extends A> acquire, Function1<? super A,? extends Kind<Task<?>,? extends B>> use, Function1<? super A,? extends Kind<Task<?>,Unit>> release)
static <A> Task<A>	Task.defer(Producer<? extends Kind<Task<?>,? extends A>> lazy)
static Task<Unit>	Task.exec(CheckedRunnable task)
<B> Task<B>	Task.flatMap(Function1<? super A,? extends Kind<Task<?>,? extends B>> map)
<B> Task<B>	Task.foldM(Function1<? super Throwable,? extends Kind<Task<?>,? extends B>> mapError, Function1<? super A,? extends Kind<Task<?>,? extends B>> map)
Task<Fiber<Task<?>,A>>	Task.fork()
static Task<Unit>	Task.forked(Executor executor)
static <A> Task<A>	Task.fromEither(Producer<Either<Throwable,? extends A>> task)
static <A> Task<A>	Task.fromEither(Either<Throwable,? extends A> task)
static <A> Task<A>	Task.fromOption(Producer<Option<? extends A>> task)
static <A> Task<A>	Task.fromOption(Option<? extends A> task)
static <A> Task<A>	Task.fromTry(Producer<Try<? extends A>> task)
static <A> Task<A>	Task.fromTry(Try<? extends A> task)
<B> Task<B>	Task.map(Function1<? super A,? extends B> map)
static <A> Task<A>	Task.never()
Task<A>	Task.orElse(Kind<Task<?>,? extends A> other)
static <A, B, C> Task<C>	Task.parMap2(Kind<Task<?>,? extends A> za, Kind<Task<?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <A, B, C> Task<C>	Task.parMap2(Executor executor, Kind<Task<?>,? extends A> za, Kind<Task<?>,? extends B> zb, Function2<? super A,? super B,? extends C> mapper)
static <A> Task<A>	Task.pure(A value)
static <A, B> Task<Either<A,B>>	Task.race(Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
static <A, B> Task<Either<A,B>>	Task.race(Executor executor, Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
static <A, B> Task<Either<Tuple2<A,Fiber<Task<?>,B>>,Tuple2<Fiber<Task<?>,A>,B>>>	Task.racePair(Executor executor, Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
static <A> Task<A>	Task.raiseError(Throwable error)
Task<A>	Task.repeat()
Task<A>	Task.repeat(int times)
Task<A>	Task.repeat(Duration delay)
Task<A>	Task.repeat(Duration delay, int times)
Task<A>	Task.retry()
Task<A>	Task.retry(int maxRetries)
Task<A>	Task.retry(Duration delay)
Task<A>	Task.retry(Duration delay, int maxRetries)
static Task<Unit>	Task.sleep(Duration delay)
static Task<Unit>	Task.sleep(Executor executor, Duration delay)
static <A> Task<A>	Task.task(Producer<? extends A> task)
Task<Tuple2<Duration,A>>	Task.timed()
Task<A>	Task.timeout(Duration duration)
Task<A>	Task.timeout(Executor executor, Duration duration)
static <A> Task<A>	TaskOf.toTask(Kind<Task<?>,? extends A> value)
Task<A>	UIO.toTask()
static <A> Task<Sequence<A>>	Task.traverse(Sequence<? extends Kind<Task<?>,A>> sequence)
static <A> Task<Sequence<A>>	Task.traverse(Executor executor, Sequence<? extends Kind<Task<?>,A>> sequence)
static Task<Unit>	Task.unit()
<B> Task<Tuple2<A,B>>	Task.zip(Kind<Task<?>,? extends B> other)
<B> Task<A>	Task.zipLeft(Kind<Task<?>,? extends B> other)
<B> Task<B>	Task.zipRight(Kind<Task<?>,? extends B> other)
<B, C> Task<C>	Task.zipWith(Kind<Task<?>,? 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 Task

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

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

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

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

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

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

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

Modifier and Type	Method	Description
default <A, B> Task<B>	TaskApplicative.ap(Kind<Task<?>,? extends A> value, Kind<Task<?>,? extends Function1<? super A,? extends B>> apply)
default <A> Task<A>	TaskAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<Task<?>,Unit>> consumer)
default <A, B> Task<B>	TaskBracket.bracket(Kind<Task<?>,? extends A> acquire, Function1<? super A,? extends Kind<Task<?>,? extends B>> use, Function1<? super A,? extends Kind<Task<?>,Unit>> release)
default <A> Task<A>	TaskDefer.defer(Producer<? extends Kind<Task<?>,? extends A>> defer)
default <A, B> Task<B>	TaskMonad.flatMap(Kind<Task<?>,? extends A> value, Function1<? super A,? extends Kind<Task<?>,? extends B>> map)
default <A> Task<Fiber<Task<?>,A>>	TaskConcurrent.fork(Kind<Task<?>,? extends A> value)
default <A> Task<A>	TaskMonadError.handleErrorWith(Kind<Task<?>,A> value, Function1<? super Throwable,? extends Kind<Task<?>,? extends A>> handler)
default <A, B> Task<B>	TaskFunctor.map(Kind<Task<?>,? extends A> value, Function1<? super A,? extends B> map)
Task<Unit>	TaskConsole.println(String text)
default <A> Task<A>	TaskPure.pure(A value)
default <A, B> Task<Either<Tuple2<A,Fiber<Task<?>,B>>,Tuple2<Fiber<Task<?>,A>,B>>>	TaskConcurrent.racePair(Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
default <A> Task<A>	TaskMonadError.raiseError(Throwable error)
Task<String>	TaskConsole.readln()
default Task<Unit>	TaskMonadDefer.sleep(Duration duration)

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

Modifier and Type	Method	Description
static Applicative<Task<?>>	TaskInstances.applicative()
static Async<Task<?>>	TaskInstances.async()
static Concurrent<Task<?>>	TaskInstances.concurrent()
static Concurrent<Task<?>>	TaskInstances.concurrent(Executor executor)
static Console<Task<?>>	TaskInstances.console()
default <A> Task<Fiber<Task<?>,A>>	TaskConcurrent.fork(Kind<Task<?>,? extends A> value)
static Functor<Task<?>>	TaskInstances.functor()
static Monad<Task<?>>	TaskInstances.monad()
static MonadDefer<Task<?>>	TaskInstances.monadDefer()
static MonadError<Task<?>,Throwable>	TaskInstances.monadError()
static MonadThrow<Task<?>>	TaskInstances.monadThrow()
static PureStream.Of<Task<?>>	PureStreamInstances.ofTask()
default <A, B> Task<Either<Tuple2<A,Fiber<Task<?>,B>>,Tuple2<Fiber<Task<?>,A>,B>>>	TaskConcurrent.racePair(Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
default <A, B> Task<Either<Tuple2<A,Fiber<Task<?>,B>>,Tuple2<Fiber<Task<?>,A>,B>>>	TaskConcurrent.racePair(Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
static <A> Reference<Task<?>,A>	TaskInstances.ref(A value)
static <A extends AutoCloseable> Resource<Task<?>,A>	TaskInstances.resource(Task<A> acquire)
static <A> Resource<Task<?>,A>	TaskInstances.resource(Task<A> acquire, Consumer1<A> release)
static Runtime<Task<?>>	TaskInstances.runtime()

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

Modifier and Type	Method	Description
static <A extends AutoCloseable> Resource<Task<?>,A>	TaskInstances.resource(Task<A> acquire)
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 Task

Modifier and Type	Method	Description
default <A, B> Task<B>	TaskApplicative.ap(Kind<Task<?>,? extends A> value, Kind<Task<?>,? extends Function1<? super A,? extends B>> apply)
default <A> Task<A>	TaskAsync.asyncF(Function1<Consumer1<? super Try<? extends A>>,Kind<Task<?>,Unit>> consumer)
default <A, B> Task<B>	TaskBracket.bracket(Kind<Task<?>,? extends A> acquire, Function1<? super A,? extends Kind<Task<?>,? extends B>> use, Function1<? super A,? extends Kind<Task<?>,Unit>> release)
default <A, B> Task<B>	TaskBracket.bracket(Kind<Task<?>,? extends A> acquire, Function1<? super A,? extends Kind<Task<?>,? extends B>> use, Function1<? super A,? extends Kind<Task<?>,Unit>> release)
default <A> Task<A>	TaskDefer.defer(Producer<? extends Kind<Task<?>,? extends A>> defer)
default <A, B> Task<B>	TaskMonad.flatMap(Kind<Task<?>,? extends A> value, Function1<? super A,? extends Kind<Task<?>,? extends B>> map)
default <A, B> Task<B>	TaskMonad.flatMap(Kind<Task<?>,? extends A> value, Function1<? super A,? extends Kind<Task<?>,? extends B>> map)
default <A> Task<Fiber<Task<?>,A>>	TaskConcurrent.fork(Kind<Task<?>,? extends A> value)
default <A> Task<A>	TaskMonadError.handleErrorWith(Kind<Task<?>,A> value, Function1<? super Throwable,? extends Kind<Task<?>,? extends A>> handler)
default <A> Task<A>	TaskMonadError.handleErrorWith(Kind<Task<?>,A> value, Function1<? super Throwable,? extends Kind<Task<?>,? extends A>> handler)
default <A, B> Task<B>	TaskFunctor.map(Kind<Task<?>,? extends A> value, Function1<? super A,? extends B> map)
default <T> Future<Sequence<T>>	TaskRuntime.parRun(Sequence<Kind<Task<?>,T>> values, Executor executor)
default <T> Future<T>	TaskRuntime.parRun(Kind<Task<?>,T> value, Executor executor)
default <A, B> Task<Either<Tuple2<A,Fiber<Task<?>,B>>,Tuple2<Fiber<Task<?>,A>,B>>>	TaskConcurrent.racePair(Kind<Task<?>,? extends A> fa, Kind<Task<?>,? extends B> fb)
default <T> Sequence<T>	TaskRuntime.run(Sequence<Kind<Task<?>,T>> values)
default <T> T	TaskRuntime.run(Kind<Task<?>,T> value)

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

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

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