Package com.singularsys.jeptests.unit.misc

Class PublishingVariableTest.BasicSubscriber

java.lang.Object

com.singularsys.jeptests.unit.misc.PublishingVariableTest.BasicSubscriber

All Implemented Interfaces:

Flow.Subscriber<VariableTableAction>

Enclosing class:

PublishingVariableTest

public class PublishingVariableTest.BasicSubscriber
extends Object
implements Flow.Subscriber<VariableTableAction>

A basic subscriber. When the onNext(VariableTableAction) method is called, it adds a item to messages.

Field Summary

Fields

Modifier and Type	Field	Description
final LinkedBlockingQueue<String>	messages

Constructor Summary

Constructors

Constructor	Description
BasicSubscriber()

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	onComplete()
void	onError(Throwable throwable)
void	onNext(VariableTableAction item)
void	onSubscribe(Flow.Subscription subscription)

Methods inherited from class java.lang.Object

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

Field Details

messages

public final LinkedBlockingQueue<String> messages

Constructor Details

BasicSubscriber

public BasicSubscriber()

Method Details

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<VariableTableAction>

onNext

public void onNext(VariableTableAction item)

Specified by:

onNext in interface Flow.Subscriber<VariableTableAction>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<VariableTableAction>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<VariableTableAction>

cancel

public void cancel()