Module id.xfunction

Package id.xfunction.concurrent.flow

Class SimpleSubscriber<T>

Object

SimpleSubscriber<T>

All Implemented Interfaces:

ReplayableSubscriber<T>, Flow.Subscriber<T>

Direct Known Subclasses:

CollectorSubscriber, FixedCollectorSubscriber

public class SimpleSubscriber<T>
extends Object
implements ReplayableSubscriber<T>

Simple implementation for Flow.Subscriber interface which can be subscribed only once.

Field Summary

Fields

Modifier and Type	Field	Description
protected Flow.Subscription	subscription

Constructor Summary

Constructors

Constructor	Description
SimpleSubscriber()

Method Summary

Modifier and Type	Method	Description
Optional<Flow.Subscription>	getSubscription()	Returns subscription if subscriber is already subscribed
boolean	isSubscribed()
void	onComplete()	Empty
void	onError(Throwable throwable)	Prints stack trace for the given exception to stderr
void	onNext(T item)	Empty
void	onSubscribe(Flow.Subscription subscription)	Saves subscription and requests withInitialRequest(int) number of items.
void	replay(T item)	Empty
SimpleSubscriber<T>	withInitialRequest(int numOfMessages)	Allows to set how many messages to request once this subscriber will be first subscribed to some topic.

Methods inherited from class Object

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

Field Details

subscription

protected Flow.Subscription subscription

Constructor Details

SimpleSubscriber

public SimpleSubscriber()

Method Details

withInitialRequest

public SimpleSubscriber<T> withInitialRequest(int numOfMessages)

Allows to set how many messages to request once this subscriber will be first subscribed to some topic. Default number is one.

onSubscribe

public void onSubscribe(Flow.Subscription subscription)
                 throws PreconditionException

Saves subscription and requests withInitialRequest(int) number of items.

Specified by:

onSubscribe in interface Flow.Subscriber<T>

Throws:

PreconditionException - if subscriber is already subscribed

onNext

public void onNext(T item)

Empty

Specified by:

onNext in interface Flow.Subscriber<T>

onError

public void onError(Throwable throwable)

Prints stack trace for the given exception to stderr

Specified by:

onError in interface Flow.Subscriber<T>

onComplete

public void onComplete()

Empty

Specified by:

onComplete in interface Flow.Subscriber<T>

getSubscription

public Optional<Flow.Subscription> getSubscription()

Returns subscription if subscriber is already subscribed

replay

public void replay(T item)

Empty

Specified by:

replay in interface ReplayableSubscriber<T>

isSubscribed

public boolean isSubscribed()