com.github.davidmoten.rx.testing

Class TestSubscriber2<T>

java.lang.Object

rx.Subscriber<T>

com.github.davidmoten.rx.testing.TestSubscriber2<T>

All Implemented Interfaces:

rx.Observer<T>, rx.Subscription

public class TestSubscriber2<T>
extends rx.Subscriber<T>

Method Summary

Modifier and Type	Method and Description
TestSubscriber2<T>	assertCompleted()
TestSubscriber2<T>	assertError(Class<? extends Throwable> clazz)
TestSubscriber2<T>	assertError(Throwable throwable)
TestSubscriber2<T>	assertNoErrors()
TestSubscriber2<T>	assertNotCompleted()
TestSubscriber2<T>	assertNoTerminalEvent()
TestSubscriber2<T>	assertNoValues()
TestSubscriber2<T>	assertReceivedOnNext(List<T> items)
TestSubscriber2<T>	assertTerminalEvent()
TestSubscriber2<T>	assertUnsubscribed()
TestSubscriber2<T>	assertValue(T value)
TestSubscriber2<T>	assertValueCount(int count)
TestSubscriber2<T>	assertValues(T... values)
TestSubscriber2<T>	assertValuesAndClear(T expectedFirstValue, T... expectedRestValues)
TestSubscriber2<T>	awaitTerminalEvent()
TestSubscriber2<T>	awaitTerminalEvent(long timeout, TimeUnit unit)
TestSubscriber2<T>	awaitTerminalEventAndUnsubscribeOnTimeout(long timeout, TimeUnit unit)
boolean	awaitValueCount(int expected, long timeout, TimeUnit unit)
static <T> TestSubscriber2<T>	createWithRequest(long initialRequest)
int	getCompletions()
Thread	getLastSeenThread()
List<Throwable>	getOnErrorEvents()
List<T>	getOnNextEvents()
int	getValueCount()
void	onCompleted()
void	onError(Throwable e)
void	onNext(T t)
void	onStart()
TestSubscriber2<T>	perform(rx.functions.Action0 action)
TestSubscriber2<T>	requestMore(long n)
void	setProducer(rx.Producer p)
String	toString()

Methods inherited from class rx.Subscriber

add, isUnsubscribed, request, unsubscribe

Methods inherited from class java.lang.Object

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

Method Detail

createWithRequest

public static <T> TestSubscriber2<T> createWithRequest(long initialRequest)

onStart

public void onStart()

Overrides:

onStart in class rx.Subscriber<T>

onCompleted

public void onCompleted()

setProducer

public void setProducer(rx.Producer p)

Overrides:

setProducer in class rx.Subscriber<T>

getCompletions

public final int getCompletions()

onError

public void onError(Throwable e)

getOnErrorEvents

public List<Throwable> getOnErrorEvents()

onNext

public void onNext(T t)

toString

public String toString()

Overrides:

toString in class Object

getValueCount

public final int getValueCount()

requestMore

public TestSubscriber2<T> requestMore(long n)

getOnNextEvents

public List<T> getOnNextEvents()

assertReceivedOnNext

public TestSubscriber2<T> assertReceivedOnNext(List<T> items)

awaitValueCount

public final boolean awaitValueCount(int expected,
                                     long timeout,
                                     TimeUnit unit)

assertTerminalEvent

public TestSubscriber2<T> assertTerminalEvent()

assertUnsubscribed

public TestSubscriber2<T> assertUnsubscribed()

assertNoErrors

public TestSubscriber2<T> assertNoErrors()

awaitTerminalEvent

public TestSubscriber2<T> awaitTerminalEvent()

awaitTerminalEvent

public TestSubscriber2<T> awaitTerminalEvent(long timeout,
                                             TimeUnit unit)

awaitTerminalEventAndUnsubscribeOnTimeout

public TestSubscriber2<T> awaitTerminalEventAndUnsubscribeOnTimeout(long timeout,
                                                                    TimeUnit unit)

getLastSeenThread

public Thread getLastSeenThread()

assertCompleted

public TestSubscriber2<T> assertCompleted()

assertNotCompleted

public TestSubscriber2<T> assertNotCompleted()

assertError

public TestSubscriber2<T> assertError(Class<? extends Throwable> clazz)

assertError

public TestSubscriber2<T> assertError(Throwable throwable)

assertNoTerminalEvent

public TestSubscriber2<T> assertNoTerminalEvent()

assertNoValues

public TestSubscriber2<T> assertNoValues()

assertValueCount

public TestSubscriber2<T> assertValueCount(int count)

assertValues

public TestSubscriber2<T> assertValues(T... values)

assertValue

public TestSubscriber2<T> assertValue(T value)

assertValuesAndClear

public final TestSubscriber2<T> assertValuesAndClear(T expectedFirstValue,
                                                     T... expectedRestValues)

perform

public final TestSubscriber2<T> perform(rx.functions.Action0 action)