de.esoco.coroutine

Class Selection<T,V,R>

java.lang.Object

de.esoco.coroutine.Suspension<T>

de.esoco.coroutine.Selection<T,V,R>

public class Selection<T,V,R>
extends Suspension<T>

A Suspension subclass that selects the suspension result from one or more of multiple continuations based on certain criteria. If a child continuation fails the selection step will also fail. If a child continuation is cancelled, it will simply be ignored.

Method Summary

Modifier and Type	Method and Description
void	add(Continuation<? extends V> rContinuation) Adds a continuation to this group.
void	cancel() Cancels this suspension.
static <T,V> Selection<T,V,java.util.Collection<V>>	ofMultipleValues(CoroutineStep<?,T> rSuspendingStep, CoroutineStep<java.util.Collection<V>,?> rResumeStep, Continuation<?> rContinuation, java.util.function.Predicate<Continuation<?>> pComplete, java.util.function.Predicate<Continuation<?>> pSelect) Creates a new instance for the selection of multiple values.
static <T> Selection<T,T,T>	ofSingleValue(CoroutineStep<?,T> rSuspendingStep, CoroutineStep<T,?> rResumeStep, Continuation<?> rContinuation, java.util.function.Predicate<Continuation<?>> pSelect) Creates a new instance for the selection of a single value.
void	seal() Seals this instance so that no more coroutines can be added with add(Continuation).
java.lang.String	toString()

Methods inherited from class de.esoco.coroutine.Suspension

continuation, fail, ifNotCancelled, isCancelled, resume, resume, suspendingStep, value, withValue

Methods inherited from class java.lang.Object

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

Method Detail

ofMultipleValues

public static <T,V> Selection<T,V,java.util.Collection<V>> ofMultipleValues(CoroutineStep<?,T> rSuspendingStep,
                                                                            CoroutineStep<java.util.Collection<V>,?> rResumeStep,
                                                                            Continuation<?> rContinuation,
                                                                            java.util.function.Predicate<Continuation<?>> pComplete,
                                                                            java.util.function.Predicate<Continuation<?>> pSelect)

Creates a new instance for the selection of multiple values. If no values are selected the result will be an empty collection.

Parameters:

rSuspendingStep - The step that initiated the suspension

rResumeStep - The step to resume the execution with

rContinuation - The continuation of the execution

pComplete - The condition for the termination of the selection

pSelect - The condition for the selection of results

Returns:

The new instance

ofSingleValue

public static <T> Selection<T,T,T> ofSingleValue(CoroutineStep<?,T> rSuspendingStep,
                                                 CoroutineStep<T,?> rResumeStep,
                                                 Continuation<?> rContinuation,
                                                 java.util.function.Predicate<Continuation<?>> pSelect)

Creates a new instance for the selection of a single value. If no value is selected the result will be NULL.

Parameters:

rSuspendingStep - The step that initiated the suspension

rResumeStep - The step to resume the execution with

rContinuation - The continuation of the execution

pSelect - The condition for the selection of results

Returns:

The new instance

add

public void add(Continuation<? extends V> rContinuation)

Adds a continuation to this group.

Parameters:

rContinuation - The continuation

cancel

public void cancel()

Cancels this suspension. This will cancel the continuation. Tries to resuming a cancelled suspension will be ignored.

Overrides:

cancel in class Suspension<T>

seal

public void seal()

Seals this instance so that no more coroutines can be added with add(Continuation). Sealing is necessary to allow the adding of further coroutines even if previously added coroutines have already finished execution.

toString

public java.lang.String toString()

Overrides:

toString in class Suspension<T>