Class IO.Compose<A>

java.lang.Object

com.jnape.palatable.lambda.io.IO<A>

com.jnape.palatable.lambda.io.IO.Compose<A>

All Implemented Interfaces:

Applicative<A,IO<?>>, Functor<A,IO<?>>, Monad<A,IO<?>>, MonadError<Throwable, A, IO<?>>, MonadRec<A,IO<?>>

Enclosing class:

IO<A>

private static final class IO.Compose<A>
extends IO<A>

Field Summary

Fields

Modifier and Type	Field	Description
private final Choice2<IO<?>, Fn1<Object,IO<?>>>	composition
private final IO<?>	source

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Compose(IO<?> source, Choice2<IO<?>, Fn1<Object,IO<?>>> composition)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<A>	unsafePerformAsyncIO(Executor executor)	Returns a CompletableFuture representing the result of this eventual effect.
A	unsafePerformIO()	Run the effect represented by this IO instance, blocking the current thread until the effect terminates.

Methods inherited from class IO

catchError, discardL, discardR, ensuring, exceptionally, externallyManaged, flatMap, fmap, fuse, interruptible, io, io, io, lazyZip, memoize, monitorSync, pin, pure, pureIO, safe, throwError, throwing, trampolineM, unsafePerformAsyncIO, zip

Methods inherited from class Object

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

Methods inherited from interface Functor

coerce

Field Details

source

private final IO<?> source

composition

private final Choice2<IO<?>, Fn1<Object,IO<?>>> composition

Constructor Details

Compose

private Compose(IO<?> source,
 Choice2<IO<?>, Fn1<Object,IO<?>>> composition)

Method Details

unsafePerformIO

public A unsafePerformIO()

Description copied from class: IO

Run the effect represented by this IO instance, blocking the current thread until the effect terminates.

Specified by:

unsafePerformIO in class IO<A>

Returns:

the result of the effect

unsafePerformAsyncIO

public CompletableFuture<A> unsafePerformAsyncIO(Executor executor)

Description copied from class: IO

Returns a CompletableFuture representing the result of this eventual effect. By default, this will immediately run the effect in terms of the provided Executor. Note that specific IO constructions may allow this method to delegate to externally-managed CompletableFuture instead of synthesizing their own.

Specified by:

unsafePerformAsyncIO in class IO<A>

Parameters:

executor - the Executor to run the CompletableFuture from

Returns:

the CompletableFuture representing this IO's eventual result

See Also:

• IO.unsafePerformAsyncIO()