Package com.oracle.coherence.concurrent.executor

Interface Task.Subscriber<T>

Type Parameters:

T - the type of result received

All Known Implementing Classes:

RecordingSubscriber, SystemOutSubscriber

Enclosing interface:

Task<T>

public static interface Task.Subscriber<T>

A receiver of items produced by a Task.Coordinator.

Method Summary

Modifier and Type	Method	Description
void	onComplete()	Invoked by a Task.Coordinator when it is known that no additional Task.Subscriber method invocations will occur or has already been terminated by an error.
void	onError(Throwable throwable)	Invoked by a Task.Coordinator when an unrecoverable error was encountered, after which no other Task.Subscriber methods are invoked.
void	onNext(T item)	Invoked when a Task.Coordinator has produced an item for consumption.
void	onSubscribe(Task.Subscription<? extends T> subscription)	Invoked prior to the Task.Subscriber methods onComplete(), onError(Throwable) and onNext(Object) being invoked for a Task.Subscription to a Task.Coordinator.

Method Details

onComplete

void onComplete()

Invoked by a Task.Coordinator when it is known that no additional Task.Subscriber method invocations will occur or has already been terminated by an error.

After this method is invoked no other Task.Subscriber methods will be called.

If this method throws an exception, the Task.Subscriber will be closed.

onError

void onError(Throwable throwable)

Invoked by a Task.Coordinator when an unrecoverable error was encountered, after which no other Task.Subscriber methods are invoked.

If this method throws an exception, the Task.Subscriber will be closed.

Parameters:

throwable - the error

onNext

void onNext(T item)

Invoked when a Task.Coordinator has produced an item for consumption.

If this method throws an exception, the Task.Subscriber will be closed.

Parameters:

item - the item (possibly null)

onSubscribe

void onSubscribe(Task.Subscription<? extends T> subscription)

Invoked prior to the Task.Subscriber methods onComplete(), onError(Throwable) and onNext(Object) being invoked for a Task.Subscription to a Task.Coordinator.

Parameters:

subscription - the Task.Subscription