com.aol.cyclops2.internal.react.async.future

Class ExecutionPipeline

java.lang.Object

com.aol.cyclops2.internal.react.async.future.ExecutionPipeline

public class ExecutionPipeline
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ExecutionPipeline()

Method Summary

Modifier and Type	Method and Description
static ExecutionPipeline	empty()
<X extends java.lang.Throwable,T> ExecutionPipeline	exceptionally(java.util.function.Function<? super X,? extends T> fn)
boolean	isSequential()
ExecutionPipeline	onFail(java.util.function.Consumer<java.lang.Throwable> onFail)
<T> ExecutionPipeline	peek(java.util.function.Consumer<? super T> c)
<T,R> ExecutionPipeline	thenApply(java.util.function.Function<T,R> fn)
<T,R> ExecutionPipeline	thenApplyAsync(java.util.function.Function<? super T,? extends R> fn, java.util.concurrent.Executor exec)
<T,R> ExecutionPipeline	thenCompose(java.util.function.Function<? super T,java.util.concurrent.CompletableFuture<? extends R>> fn)
<T,R> ExecutionPipeline	thenComposeAsync(java.util.function.Function<java.lang.Object,java.util.concurrent.CompletableFuture<?>> fn, java.util.concurrent.Executor exec)
FinalPipeline	toFinalPipeline()
<X extends java.lang.Throwable,T> ExecutionPipeline	whenComplete(java.util.function.BiConsumer<? super T,? super X> fn)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionPipeline

public ExecutionPipeline()

Method Detail

isSequential

public boolean isSequential()

peek

public <T> ExecutionPipeline peek(java.util.function.Consumer<? super T> c)

thenApplyAsync

public <T,R> ExecutionPipeline thenApplyAsync(java.util.function.Function<? super T,? extends R> fn,
                                              java.util.concurrent.Executor exec)

thenComposeAsync

public <T,R> ExecutionPipeline thenComposeAsync(java.util.function.Function<java.lang.Object,java.util.concurrent.CompletableFuture<?>> fn,
                                                java.util.concurrent.Executor exec)

thenCompose

public <T,R> ExecutionPipeline thenCompose(java.util.function.Function<? super T,java.util.concurrent.CompletableFuture<? extends R>> fn)

thenApply

public <T,R> ExecutionPipeline thenApply(java.util.function.Function<T,R> fn)

exceptionally

public <X extends java.lang.Throwable,T> ExecutionPipeline exceptionally(java.util.function.Function<? super X,? extends T> fn)

whenComplete

public <X extends java.lang.Throwable,T> ExecutionPipeline whenComplete(java.util.function.BiConsumer<? super T,? super X> fn)

toFinalPipeline

public FinalPipeline toFinalPipeline()

empty

public static ExecutionPipeline empty()

onFail

public ExecutionPipeline onFail(java.util.function.Consumer<java.lang.Throwable> onFail)