Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.subscribers |
Default wrappers and implementations for Subscriber-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestSubscriber that allows unit testing
Flowable -based flows. |
Modifier and Type | Method and Description |
---|---|
TestSubscriber<T> |
Flowable.test()
Creates a TestSubscriber that requests Long.MAX_VALUE and subscribes
it to this Flowable.
|
TestSubscriber<T> |
Flowable.test(long initialRequest)
Creates a TestSubscriber with the given initial request amount and subscribes
it to this Flowable.
|
TestSubscriber<T> |
Flowable.test(long initialRequest,
boolean cancel)
Creates a TestSubscriber with the given initial request amount,
optionally cancels it before the subscription and subscribes
it to this Flowable.
|
Modifier and Type | Method and Description |
---|---|
TestSubscriber<T> |
TestSubscriber.assertNotSubscribed()
Assert that the onSubscribe method hasn't been called at all.
|
TestSubscriber<T> |
TestSubscriber.assertOf(Consumer<? super TestSubscriber<T>> check)
Run a check consumer with this TestSubscriber instance.
|
TestSubscriber<T> |
TestSubscriber.assertSubscribed()
Assert that the onSubscribe method was called exactly once.
|
static <T> TestSubscriber<T> |
TestSubscriber.create()
Creates a TestSubscriber with Long.MAX_VALUE initial request.
|
static <T> TestSubscriber<T> |
TestSubscriber.create(long initialRequested)
Creates a TestSubscriber with the given initial request.
|
static <T> TestSubscriber<T> |
TestSubscriber.create(org.reactivestreams.Subscriber<? super T> delegate)
Constructs a forwarding TestSubscriber.
|
TestSubscriber<T> |
TestSubscriber.requestMore(long n)
Calls
request(long) and returns this. |
Modifier and Type | Method and Description |
---|---|
TestSubscriber<T> |
TestSubscriber.assertOf(Consumer<? super TestSubscriber<T>> check)
Run a check consumer with this TestSubscriber instance.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.