| Package | Description |
|---|---|
| rx.observers |
| Modifier and Type | Method and Description |
|---|---|
static <T> TestSubscriber |
TestSubscriber.create()
Factory method to construct a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation.
|
static <T> TestSubscriber |
TestSubscriber.create(long initialRequest)
Factory method to construct a TestSubscriber with the given initial request amount and no delegation.
|
static <T> TestSubscriber |
TestSubscriber.create(Observer
Factory method to construct a TestSubscriber which delegates events to the given Subscriber and an issues an initial request of Long.MAX_VALUE.
|
static <T> TestSubscriber |
TestSubscriber.create(Observer
Factory method to construct a TestSubscriber which delegates events to the given Observer and issues the given initial request amount.
|
static <T> TestSubscriber |
TestSubscriber.create(Subscriber
Factory method to construct a TestSubscriber which delegates events to the given Observer and an issues an initial request of Long.MAX_VALUE.
|