Package io.foldright.cffu2

Class Cffu<T>

java.lang.Object

io.foldright.cffu2.BaseCffu<T,Cffu<T>>

io.foldright.cffu2.Cffu<T>

Type Parameters:

T - The result collection type returned by this future's join

All Implemented Interfaces:

CompletionStage<T>, Future<T>

public final class Cffu<T>
extends BaseCffu<T,Cffu<T>>
implements Future<T>, CompletionStage<T>

This class Cffu is the equivalent class to CompletableFuture, contains the equivalent instance methods of CompletionStage and CompletableFuture.

The methods that equivalent to static factory methods of CompletableFuture is in CffuFactory class.

Author:

Jerry Lee (oldratlee at gmail dot com), HuHao (995483610 at qq dot com)

See Also:

• CffuFactoryBuilder
• CffuFactory
• CompletionStage
• CompletableFuture
• MCffu

Nested Class Summary

Nested classes/interfaces inherited from class io.foldright.cffu2.BaseCffu

BaseCffu.IterableOps, BaseCffu.TupleOps

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Method Summary

Modifier and Type	Method	Description
static <E, U extends Iterable<? extends E>> MCffu<E,U>	asMCffu(Cffu<U> cffu)	Converts to MCffu, reuse the underlying CompletableFuture instance and rewraps it to MCffu.

Methods inherited from class io.foldright.cffu2.BaseCffu

acceptEither, acceptEitherAsync, acceptEitherAsync, acceptEitherSuccess, acceptEitherSuccessAsync, acceptEitherSuccessAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, applyToEitherSuccess, applyToEitherSuccessAsync, applyToEitherSuccessAsync, cancel, catching, catchingAsync, catchingAsync, catchingCompose, catchingComposeAsync, catchingComposeAsync, cffuFactory, cffuState, cffuUnwrap, complete, completeAsync, completeAsync, completeExceptionally, completeExceptionallyAsync, completeExceptionallyAsync, completeOnTimeout, copy, defaultExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, exceptionNow, forbidObtrudeMethods, get, get, getNow, getNumberOfDependents, getSuccessNow, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, isMinimalStage, iterableOps, join, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, peek, peekAsync, peekAsync, resultNow, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterBothFailFast, runAfterBothFailFastAsync, runAfterBothFailFastAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAfterEitherSuccess, runAfterEitherSuccessAsync, runAfterEitherSuccessAsync, state, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenAcceptBothFailFast, thenAcceptBothFailFastAsync, thenAcceptBothFailFastAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCombineFailFast, thenCombineFailFastAsync, thenCombineFailFastAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenMAcceptAnyAsync, thenMAcceptAnyAsync, thenMAcceptAnySuccessAsync, thenMAcceptAnySuccessAsync, thenMAcceptAsync, thenMAcceptAsync, thenMAcceptAsyncAndForget, thenMAcceptAsyncAndForget, thenMAcceptFailFastAsync, thenMAcceptFailFastAsync, thenMApplyAllSuccessAsync, thenMApplyAllSuccessAsync, thenMApplyAnyAsync, thenMApplyAnyAsync, thenMApplyAnySuccessAsync, thenMApplyAnySuccessAsync, thenMApplyAsync, thenMApplyAsync, thenMApplyFailFastAsync, thenMApplyFailFastAsync, thenMApplyMostSuccessAsync, thenMApplyMostSuccessAsync, thenMRunAnyAsync, thenMRunAnyAsync, thenMRunAnySuccessAsync, thenMRunAnySuccessAsync, thenMRunAsync, thenMRunAsync, thenMRunAsyncAndForget, thenMRunAsyncAndForget, thenMRunFailFastAsync, thenMRunFailFastAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, tupleOps, unsafeCompleteOnTimeout, unsafeOrTimeout, whenComplete, whenCompleteAsync, whenCompleteAsync, withCffuFactory, withDefaultExecutor

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.CompletionStage

acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, handle, handleAsync, handleAsync, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from interface java.util.concurrent.Future

cancel, exceptionNow, get, get, isCancelled, isDone, resultNow, state

Method Details

asMCffu

@Contract(pure=true)
public static <E,
U extends Iterable<? extends E>>
MCffu<E,U> asMCffu(Cffu<U> cffu)

Converts to MCffu, reuse the underlying CompletableFuture instance and rewraps it to MCffu.

Type Parameters:

E - the data element type of result collection

See Also:

• MCffu.asCffu()
• CffuFactory.toMCffu(CompletionStage)