Package com.oracle.coherence.concurrent.executor

Interface Task.SubscribedOrchestration<T>

Type Parameters:

T - the type of results produced by a Task

All Known Subinterfaces:

Task.Orchestration<T>

Enclosing interface:

Task<T>

public static interface Task.SubscribedOrchestration<T>

Defines the subset of Task.Orchestration methods which are permitted after subscribe(Subscriber) is called. Once subscribe(Subscriber) is called, only two methods are permitted: more subscribe(Subscriber) calls, or submit().

See Also:

• Task.Orchestration

Method Summary

Modifier and Type	Method	Description
Task.Coordinator<T>	submit()	Submits the Task for orchestration by the TaskExecutorService.
Task.SubscribedOrchestration<T>	subscribe(Task.Subscriber<? super T> subscriber)	Registers the specified Task.Subscriber as part of the orchestration of the Task.

Method Details

subscribe

Task.SubscribedOrchestration<T> subscribe(Task.Subscriber<? super T> 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.

This method is mutually exclusive to Task.Orchestration.collect(Collector). To subscribe when using a Task.Collector, use Task.Collectable.subscribe(Subscriber) on the Task.Collectable returned by Task.Orchestration.collect(Collector).

Parameters:

subscriber - the Task.Subscriber

Returns:

the Task.Orchestration to permit fluent-style method chaining

See Also:

• Task.Collectable.subscribe(Subscriber)

submit

Task.Coordinator<T> submit()

Submits the Task for orchestration by the TaskExecutorService.

Returns:

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

See Also:

• Task.Collectable.subscribe(Subscriber)