rx.testkit

Class AssertObservable<T>

java.lang.Object

org.assertj.core.api.AbstractAssert<AssertObservable<T>,io.reactivex.Observable<T>>

rx.testkit.AssertObservable<T>

All Implemented Interfaces:

org.assertj.core.api.Assert<AssertObservable<T>,io.reactivex.Observable<T>>, org.assertj.core.api.Descriptable<AssertObservable<T>>, org.assertj.core.api.ExtensionPoints<AssertObservable<T>,io.reactivex.Observable<T>>

public class AssertObservable<T>
extends org.assertj.core.api.AbstractAssert<AssertObservable<T>,io.reactivex.Observable<T>>

AssertJ Assert class for Observable. Uses TestSubscriber from Rx to subscribe to and Observable and perform assertions on the results. Optionally, a TestScheduler can be used to perform async testing.

Field Summary

Fields inherited from class org.assertj.core.api.AbstractAssert

actual, info, myself

Method Summary

Modifier and Type	Method and Description
AssertObservable<T>	after(long duration, java.util.concurrent.TimeUnit timeUnit) If a TestScheduler is provided, advanced the time by the specified duration.
static <T> AssertObservable<T>	assertThat(io.reactivex.Observable<T> observable) Constructs an AssertObservable for a given Observable.
static <T> AssertObservable<T>	assertThat(io.reactivex.Observable<T> observable, io.reactivex.schedulers.TestScheduler scheduler) Constructs an AssertObservable for a given Observable with a TestScheduler.
org.assertj.core.api.AbstractListAssert<?,? extends java.util.List<? extends java.lang.Throwable>,java.lang.Throwable>	failures() Create a ListAssert for the failures emitted.
AssertObservable<T>	hasCompleted() Assert that the underlying Observable has completed.
AssertObservable<T>	hasNotCompleted() Assert that the underlying Observable has *not* completed.
org.assertj.core.api.AbstractListAssert<?,? extends java.util.List<? extends T>,T>	values() Create a ListAssert for the values emitted.

Methods inherited from class org.assertj.core.api.AbstractAssert

as, as, asList, asString, describedAs, describedAs, descriptionText, doesNotHave, doesNotHaveSameClassAs, equals, failWithMessage, getWritableAssertionInfo, has, hashCode, hasSameClassAs, hasToString, inBinary, inHexadecimal, is, isEqualTo, isExactlyInstanceOf, isIn, isIn, isInstanceOf, isInstanceOfAny, isNot, isNotEqualTo, isNotExactlyInstanceOf, isNotIn, isNotIn, isNotInstanceOf, isNotInstanceOfAny, isNotNull, isNotOfAnyClassIn, isNotSameAs, isNull, isOfAnyClassIn, isSameAs, overridingErrorMessage, usingComparator, usingDefaultComparator, withFailMessage, withThreadDumpOnError

Methods inherited from class java.lang.Object

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

Method Detail

assertThat

public static <T> AssertObservable<T> assertThat(io.reactivex.Observable<T> observable)

Constructs an AssertObservable for a given Observable.

Type Parameters:

T - the return type of the Observable

Parameters:

observable - the Observable to perform assertions on.

Returns:

an AssertObservable instance

assertThat

public static <T> AssertObservable<T> assertThat(io.reactivex.Observable<T> observable,
                                                 io.reactivex.schedulers.TestScheduler scheduler)

Constructs an AssertObservable for a given Observable with a TestScheduler. Used for async testing.

Type Parameters:

T - the return type of the Observable

Parameters:

observable - the Observable.

scheduler - the test scheduler to use

Returns:

an AssertObservable instance.

hasCompleted

public AssertObservable<T> hasCompleted()

Assert that the underlying Observable has completed.

Returns:

the AssertObservable instance

hasNotCompleted

public AssertObservable<T> hasNotCompleted()

Assert that the underlying Observable has *not* completed.

Returns:

the AssertObservable instance

values

public org.assertj.core.api.AbstractListAssert<?,? extends java.util.List<? extends T>,T> values()

Create a ListAssert for the values emitted.

Returns:

a ListAssert instance

failures

public org.assertj.core.api.AbstractListAssert<?,? extends java.util.List<? extends java.lang.Throwable>,java.lang.Throwable> failures()

Create a ListAssert for the failures emitted.

Returns:

a ListAssert instance

after

public AssertObservable<T> after(long duration,
                                 java.util.concurrent.TimeUnit timeUnit)

If a TestScheduler is provided, advanced the time by the specified duration. Throws an IllegalStateException if there is no TestScheduler provided. Use AssertObservable(Observable, TestScheduler) to construct an AssertObservable instance that can be used for async testing.

Parameters:

duration - the time duration

timeUnit - the time unit of the duration

Returns:

the AssertObservableInstance.