tour

Class SubscriberHelpers.PrintSubscriber<T>

java.lang.Object

tour.SubscriberHelpers.ObservableSubscriber<T>

tour.SubscriberHelpers.OperationSubscriber<T>

tour.SubscriberHelpers.PrintSubscriber<T>

Type Parameters:

T - The publishers result type

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Enclosing class:

SubscriberHelpers

public static class SubscriberHelpers.PrintSubscriber<T>
extends SubscriberHelpers.OperationSubscriber<T>

A Subscriber that prints a message including the received items on completion

Constructor Summary

Constructors

Constructor and Description
SubscriberHelpers.PrintSubscriber(String message) A Subscriber that outputs a message onComplete.

Method Summary

Methods

Modifier and Type	Method and Description
void	onComplete()

Methods inherited from class tour.SubscriberHelpers.OperationSubscriber

onSubscribe

Methods inherited from class tour.SubscriberHelpers.ObservableSubscriber

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriberHelpers.PrintSubscriber

public SubscriberHelpers.PrintSubscriber(String message)

A Subscriber that outputs a message onComplete.

Parameters:

message - the message to output onComplete

Method Detail

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

Overrides:

onComplete in class SubscriberHelpers.ObservableSubscriber<T>