tour

Class SubscriberHelpers.OperationSubscriber<T>

java.lang.Object

tour.SubscriberHelpers.ObservableSubscriber<T>

tour.SubscriberHelpers.OperationSubscriber<T>

Type Parameters:

T - The publishers result type

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

SubscriberHelpers.PrintDocumentSubscriber, SubscriberHelpers.PrintSubscriber

Enclosing class:

SubscriberHelpers

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

A Subscriber that immediately requests Integer.MAX_VALUE onSubscribe

Constructor Summary

Constructors

Constructor and Description
SubscriberHelpers.OperationSubscriber()

Method Summary

Methods

Modifier and Type	Method and Description
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class tour.SubscriberHelpers.ObservableSubscriber

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriberHelpers.OperationSubscriber

public SubscriberHelpers.OperationSubscriber()

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

Overrides:

onSubscribe in class SubscriberHelpers.ObservableSubscriber<T>