Task.Subscriber (Java API Reference for Oracle® Coherence Community Edition)

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

All Methods Instance Methods Abstract Methods
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 Detail
  - 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