Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.observers |
Default wrappers and implementations for Observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver that allows unit testing
Observable -, Single -, Maybe -
and Completable -based flows. |
Modifier and Type | Method and Description |
---|---|
TestObserver<Void> |
Completable.test()
Creates a TestObserver and subscribes
it to this Completable.
|
TestObserver<T> |
Maybe.test()
Creates a TestObserver and subscribes
it to this Maybe.
|
TestObserver<T> |
Single.test()
Creates a TestObserver and subscribes
it to this Single.
|
TestObserver<T> |
Observable.test()
Creates a TestObserver and subscribes
it to this Observable.
|
TestObserver<Void> |
Completable.test(boolean cancelled)
Creates a TestObserver optionally in cancelled state, then subscribes it to this Completable.
|
TestObserver<T> |
Maybe.test(boolean cancelled)
Creates a TestObserver optionally in cancelled state, then subscribes it to this Maybe.
|
TestObserver<T> |
Single.test(boolean cancelled)
Creates a TestObserver optionally in cancelled state, then subscribes it to this Single.
|
TestObserver<T> |
Observable.test(boolean dispose)
Creates a TestObserver, optionally disposes it and then subscribes
it to this Observable.
|
Modifier and Type | Method and Description |
---|---|
TestObserver<T> |
TestObserver.assertNotSubscribed()
Assert that the onSubscribe method hasn't been called at all.
|
TestObserver<T> |
TestObserver.assertOf(Consumer<? super TestObserver<T>> check)
Run a check consumer with this TestObserver instance.
|
TestObserver<T> |
TestObserver.assertSubscribed()
Assert that the onSubscribe method was called exactly once.
|
static <T> TestObserver<T> |
TestObserver.create()
Constructs a non-forwarding TestObserver.
|
static <T> TestObserver<T> |
TestObserver.create(Observer<? super T> delegate)
Constructs a forwarding TestObserver.
|
Modifier and Type | Method and Description |
---|---|
TestObserver<T> |
TestObserver.assertOf(Consumer<? super TestObserver<T>> check)
Run a check consumer with this TestObserver instance.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.