tour

Class SubscriberHelpers.ObservableSubscriber<T>

java.lang.Object

tour.SubscriberHelpers.ObservableSubscriber<T>

Type Parameters:

T - The publishers result type

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

SubscriberHelpers.OperationSubscriber

Enclosing class:

SubscriberHelpers

public static class SubscriberHelpers.ObservableSubscriber<T>
extends Object
implements org.reactivestreams.Subscriber<T>

A Subscriber that stores the publishers results and provides a latch so can block on completion.

Method Summary

Methods

Modifier and Type	Method and Description
SubscriberHelpers.ObservableSubscriber<T>	await()
SubscriberHelpers.ObservableSubscriber<T>	await(long timeout, TimeUnit unit)
List<T>	get(long timeout, TimeUnit unit)
Throwable	getError()
List<T>	getReceived()
org.reactivestreams.Subscription	getSubscription()
boolean	isCompleted()
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

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

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

getSubscription

public org.reactivestreams.Subscription getSubscription()

getReceived

public List<T> getReceived()

getError

public Throwable getError()

isCompleted

public boolean isCompleted()

get

public List<T> get(long timeout,
          TimeUnit unit)
            throws Throwable

Throws:

Throwable

await

public SubscriberHelpers.ObservableSubscriber<T> await()
                                                throws Throwable

Throws:

Throwable

await

public SubscriberHelpers.ObservableSubscriber<T> await(long timeout,
                                              TimeUnit unit)
                                                throws Throwable

Throws:

Throwable