Package | Description |
---|---|
rx.observers |
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
|
Modifier and Type | Method and Description |
---|---|
static <T> TestSubscriber<T> |
TestSubscriber.create()
Factory method to construct a TestSubscriber with an initial request of Long.MAX_VALUE and no delegation.
|
static <T> TestSubscriber<T> |
TestSubscriber.create(long initialRequest)
Factory method to construct a TestSubscriber with the given initial request amount and no delegation.
|
static <T> TestSubscriber<T> |
TestSubscriber.create(Observer<T> delegate)
Factory method to construct a TestSubscriber which delegates events to the given Observer and
an issues an initial request of Long.MAX_VALUE.
|
static <T> TestSubscriber<T> |
TestSubscriber.create(Observer<T> delegate,
long initialRequest)
Factory method to construct a TestSubscriber which delegates events to the given Observer and
issues the given initial request amount.
|
static <T> TestSubscriber<T> |
TestSubscriber.create(Subscriber<T> delegate)
Factory method to construct a TestSubscriber which delegates events to the given Subscriber and
an issues an initial request of Long.MAX_VALUE.
|
Copyright © 2024. All rights reserved.