Package io.foldright.cffu2

Class MCffu<E,T extends Iterable<? extends E>>

java.lang.Object

io.foldright.cffu2.BaseCffu<T,MCffu<E,T>>

io.foldright.cffu2.MCffu<E,T>

Type Parameters:

E - the data element type of result collection

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

All Implemented Interfaces:

CompletionStage<T>, Future<T>

public final class MCffu<E,T extends Iterable<? extends E>>
extends BaseCffu<T,MCffu<E,T>>
implements Future<T>, CompletionStage<T>

Cffu with result type Iterable (aka. multiply data/collection), MCffu<E, List<E>> is same as Cffu<List<E>> except with more methods.

Author:

Jerry Lee (oldratlee at gmail dot com)

See Also:

• Cffu

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	MCffu.ParOps	The methods for parallel data processing.

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
Cffu<T>	asCffu()	Converts to Cffu, reuse the underlying CompletableFuture instance and rewraps it to Cffu.
MCffu<E,T>.ParOps	parOps()	Returns a MCffu<E,T extends Iterable<? extends E>>.ParOps instance to access the methods for parallel data processing.

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, thenMAcceptFailFastAsync, thenMAcceptFailFastAsync, thenMApplyAllSuccessAsync, thenMApplyAllSuccessAsync, thenMApplyAnyAsync, thenMApplyAnyAsync, thenMApplyAnySuccessAsync, thenMApplyAnySuccessAsync, thenMApplyAsync, thenMApplyAsync, thenMApplyFailFastAsync, thenMApplyFailFastAsync, thenMApplyMostSuccessAsync, thenMApplyMostSuccessAsync, thenMRunAnyAsync, thenMRunAnyAsync, thenMRunAnySuccessAsync, thenMRunAnySuccessAsync, thenMRunAsync, thenMRunAsync, 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

asCffu

@Contract(pure=true)
public Cffu<T> asCffu()

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

See Also:

• Cffu.asMCffu(Cffu)
• CffuFactory.toCffu(CompletionStage)

parOps

public MCffu<E,T>.ParOps parOps()

Returns a MCffu<E,T extends Iterable<? extends E>>.ParOps instance to access the methods for parallel data processing.

See Also:

• CffuFactory.parOps()
• CfParallelUtils