Package org.reactivestreams.example.unicast

Class SyncSubscriber<T>

java.lang.Object

org.reactivestreams.example.unicast.SyncSubscriber<T>

All Implemented Interfaces:

Subscriber<T>

public abstract class SyncSubscriber<T>
extends java.lang.Object
implements Subscriber<T>

SyncSubscriber is an implementation of Reactive Streams `Subscriber`, it runs synchronously (on the Publisher's thread) and requests one element at a time and invokes a user-defined method to process each element. NOTE: The code below uses a lot of try-catches to show the reader where exceptions can be expected, and where they are forbidden.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	done
private Subscription	subscription

Constructor Summary

Constructors

Constructor	Description
SyncSubscriber()

Method Summary

Modifier and Type	Method	Description
private void	done()
void	onComplete()	Successful terminal state.
void	onError(java.lang.Throwable t)	Failed terminal state.
void	onNext(T element)	Data notification sent by the Publisher in response to requests to Subscription.request(long).
void	onSubscribe(Subscription s)	Invoked after calling Publisher.subscribe(Subscriber).
protected abstract boolean	whenNext(T element)

Methods inherited from class java.lang.Object

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

Field Detail

subscription

private Subscription subscription

done

private boolean done

Constructor Detail

SyncSubscriber

public SyncSubscriber()

Method Detail

onSubscribe

public void onSubscribe(Subscription s)

Description copied from interface: Subscriber

Invoked after calling Publisher.subscribe(Subscriber).

No data will start flowing until Subscription.request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription.request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription.request(long).

Specified by:

onSubscribe in interface Subscriber<T>

Parameters:

s - the Subscription that allows requesting data via Subscription.request(long)

onNext

public void onNext(T element)

Description copied from interface: Subscriber

Data notification sent by the Publisher in response to requests to Subscription.request(long).

Specified by:

onNext in interface Subscriber<T>

Parameters:

element - the element signaled

done

private void done()

whenNext

protected abstract boolean whenNext(T element)

onError

public void onError(java.lang.Throwable t)

Description copied from interface: Subscriber

Failed terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.

Specified by:

onError in interface Subscriber<T>

Parameters:

t - the throwable signaled

onComplete

public void onComplete()

Description copied from interface: Subscriber

Successful terminal state.

No further events will be sent even if Subscription.request(long) is invoked again.

Specified by:

onComplete in interface Subscriber<T>