Package com.oracle.coherence.concurrent.executor

Class TaskCollectors

java.lang.Object

com.oracle.coherence.concurrent.executor.TaskCollectors

public final class TaskCollectors
extends Object

Static helper methods to create Task.Collectors.

Since:

21.06

Author:

bo

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TaskCollectors.CountCollector<T>	A Task.Collector that counts the number of results are present.
static class	TaskCollectors.FirstOfCollector<T>	A Task.Collector to collect any (the first provided) available result.
static class	TaskCollectors.LastOfCollector<T>	A Task.Collector that collects and returns the last contributed result.
static class	TaskCollectors.ListOfCollector<T>	A Task.Collector that collects and returns all contributed results that are values as a List.
static class	TaskCollectors.SetOfCollector<T>	A Task.Collector that collects and returns all contributed results that are values as a Set.

Method Summary

Modifier and Type	Method	Description
static <T> Task.Collector<? super T,?,Integer>	count()	A Task.Collector that counts the number of non-null results that have been made.
static <T> Task.Collector<T,?,T>	firstOf()	A Task.Collector that will collect the first provided result.
static <T> Task.Collector<T,?,T>	lastOf()	A Task.Collector that returns the last added result, when all results have been provided.
static <T> Task.Collector<T,?,List<T>>	listOf()	A Task.Collector that returns the List of results that are values.
static <T> Task.Collector<T,?,Set<T>>	setOf()	A Task.Collector that returns the Set of results that are values.

Methods inherited from class java.lang.Object

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

Method Details

listOf

public static <T> Task.Collector<T,?,List<T>> listOf()

A Task.Collector that returns the List of results that are values.

Type Parameters:

T - the type of the result

Returns:

a Task.Collector

setOf

public static <T> Task.Collector<T,?,Set<T>> setOf()

A Task.Collector that returns the Set of results that are values.

Type Parameters:

T - the type of the result

Returns:

a Task.Collector

lastOf

public static <T> Task.Collector<T,?,T> lastOf()

A Task.Collector that returns the last added result, when all results have been provided.

Type Parameters:

T - the type of the result

Returns:

a Task.Collector

count

public static <T>
Task.Collector<? super T,?,Integer> count()

A Task.Collector that counts the number of non-null results that have been made.

Type Parameters:

T - the type of result

Returns:

a Task.Collector

firstOf

public static <T> Task.Collector<T,?,T> firstOf()

A Task.Collector that will collect the first provided result.

Type Parameters:

T - the type of result

Returns:

a Task.Collector