Package com.oracle.coherence.concurrent.executor.subscribers

Class SystemOutSubscriber<T>

java.lang.Object

com.oracle.coherence.concurrent.executor.subscribers.SystemOutSubscriber<T>

Type Parameters:

T - the type of result received

All Implemented Interfaces:

Task.Subscriber<T>

public class SystemOutSubscriber<T>
extends Object
implements Task.Subscriber<T>

A Task.Subscriber that logs interactions to the System.out.

Since:

21.12

Author:

bo

Field Summary

Fields

Modifier and Type	Field	Description
protected Task.Subscription	m_subscription	The Task.Subscription for the Task.Subscriber.

Constructor Summary

Constructors

Constructor	Description
SystemOutSubscriber()

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 subscription)	Invoked prior to the Task.Subscriber methods Task.Subscriber.onComplete(), Task.Subscriber.onError(Throwable) and Task.Subscriber.onNext(Object) being invoked for a Task.Subscription to a Task.Coordinator.

Methods inherited from class java.lang.Object

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

Field Details

m_subscription

protected Task.Subscription m_subscription

The Task.Subscription for the Task.Subscriber.

Constructor Details

SystemOutSubscriber

public SystemOutSubscriber()

Method Details

onComplete

public void onComplete()

Description copied from interface: Task.Subscriber

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.

Specified by:

onComplete in interface Task.Subscriber<T>

onError

public void onError(Throwable throwable)

Description copied from interface: Task.Subscriber

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.

Specified by:

onError in interface Task.Subscriber<T>

Parameters:

throwable - the error

onNext

public void onNext(T item)

Description copied from interface: Task.Subscriber

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

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

Specified by:

onNext in interface Task.Subscriber<T>

Parameters:

item - the item (possibly null)

onSubscribe

public void onSubscribe(Task.Subscription subscription)

Description copied from interface: Task.Subscriber

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

Specified by:

onSubscribe in interface Task.Subscriber<T>

Parameters:

subscription - the Task.Subscription