tour

Class SubscriberHelpers.PrintDocumentSubscriber

java.lang.Object

tour.SubscriberHelpers.ObservableSubscriber<T>

tour.SubscriberHelpers.OperationSubscriber<Document>

tour.SubscriberHelpers.PrintDocumentSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<Document>

Enclosing class:

SubscriberHelpers

public static class SubscriberHelpers.PrintDocumentSubscriber
extends SubscriberHelpers.OperationSubscriber<Document>

A Subscriber that prints the json version of each document

Constructor Summary

Constructors

Constructor and Description
PrintDocumentSubscriber()

Method Summary

Modifier and Type	Method and Description
void	onNext(Document document)

Methods inherited from class tour.SubscriberHelpers.OperationSubscriber

onSubscribe

Methods inherited from class tour.SubscriberHelpers.ObservableSubscriber

await, await, get, getError, getReceived, getSubscription, isCompleted, onComplete, onError

Methods inherited from class java.lang.Object

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

Constructor Detail

PrintDocumentSubscriber

public PrintDocumentSubscriber()

Method Detail

onNext

public void onNext(Document document)

Specified by:

onNext in interface org.reactivestreams.Subscriber<Document>

Overrides:

onNext in class SubscriberHelpers.ObservableSubscriber<Document>