Package com.oracle.coherence.concurrent.executor

Interface Task.Collectable<T,R>

Type Parameters:

T - the type of the Task

R - the type of the result

All Known Subinterfaces:

Task.Completable<T,R>

Enclosing interface:

Task<T>

public static interface Task.Collectable<T,R>

Provides the mechanism to submit, orchestrate and collect results from a Task defined as part of an Task.Orchestration, including the creation of a Task.Coordinator to subscribe to results, manage and interact with an orchestrated Task.

A Task.Collectable represents the last part of an Task.Orchestration definition pipeline.

See Also:

• Task.Orchestration

Method Summary

Modifier and Type	Method	Description
Task.Completable<T,R>	andThen(Task.CompletionRunnable<? super R> completionRunnable)	Provide a runnable to call when the task has completed.
Task.Coordinator<R>	submit()	Submits the Task.Collectable for orchestration by a TaskExecutorService.
Task.Collectable<T,R>	subscribe(Task.Subscriber<? super R> subscriber)	Registers the specified Task.Subscriber as part of the orchestration of the Task.
Task.Completable<T,R>	until(Remote.Predicate<? super R> predicate)	Sets the Remote.Predicate to determine when the collection of results will be considered completed, based on the collected result, after which no further results will be published to Task.Subscribers.

Method Details

until

Task.Completable<T,R> until(Remote.Predicate<? super R> predicate)

Sets the Remote.Predicate to determine when the collection of results will be considered completed, based on the collected result, after which no further results will be published to Task.Subscribers.

When collection activity is completed, Task.Subscribers will then be notified by calling Task.Subscriber.onComplete().

Parameters:

predicate - the Remote.Predicate to determine when the Task has completed (based on the collected results) or null to indicate continuous collection and publishing of results

Returns:

a Task.Collectable to permit fluent-style method chaining

andThen

Task.Completable<T,R> andThen(Task.CompletionRunnable<? super R> completionRunnable)

Provide a runnable to call when the task has completed.

Parameters:

completionRunnable - the Task.CompletionRunnable to call when the Task has completed

Returns:

a Task.Collectable to permit fluent-style method chaining

subscribe

Task.Collectable<T,R> subscribe(Task.Subscriber<? super R> subscriber)

Registers the specified Task.Subscriber as part of the orchestration of the Task.

This method may be used multiple times to register multiple Task.Subscribers.

Parameters:

subscriber - the Task.Subscriber

Returns:

the Task.Collectable to permit fluent-style method chaining

submit

Task.Coordinator<R> submit()

Submits the Task.Collectable for orchestration by a TaskExecutorService.

Returns:

a Task.Coordinator for managing an orchestrated Task and publishing of collected results to Task.Subscribers