Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.observables |
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
|
rx.plugins |
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
|
rx.subjects |
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.create(Observable.OnSubscribe<T> f)
This method requires advanced knowledge about building operators and data sources; please consider
other standard methods first;
Returns an Observable that will execute the specified function when a
Subscriber subscribes to
it. |
Modifier and Type | Method and Description |
---|---|
<R> R |
Observable.extend(Func1<? super Observable.OnSubscribe<T>,? extends R> conversion)
Passes all emitted values from this Observable to the provided conversion function to be collected and
returned as a single value.
|
Constructor and Description |
---|
Observable(Observable.OnSubscribe<T> f)
Creates an Observable with a Function to execute when it is subscribed to.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncOnSubscribe<S,T>
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
class |
SyncOnSubscribe<S,T>
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
Modifier and Type | Method and Description |
---|---|
static <K,T> GroupedObservable<K,T> |
GroupedObservable.create(K key,
Observable.OnSubscribe<T> f)
Returns an Observable that will execute the specified function when a
Subscriber subscribes to
it. |
Constructor and Description |
---|
ConnectableObservable(Observable.OnSubscribe<T> onSubscribe) |
GroupedObservable(K key,
Observable.OnSubscribe<T> onSubscribe) |
Modifier and Type | Method and Description |
---|---|
static <T> Observable.OnSubscribe<T> |
RxJavaHooks.onCreate(Observable.OnSubscribe<T> onSubscribe)
Hook to call when an Observable is created.
|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f)
Deprecated.
|
static <T> Observable.OnSubscribe<T> |
RxJavaHooks.onObservableStart(Observable<T> instance,
Observable.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
static <T> Observable.OnSubscribe<T> |
RxJavaHooks.onSingleStart(Single<T> instance,
Observable.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance,
Observable.OnSubscribe<T> onSubscribe)
Deprecated.
|
<T> Observable.OnSubscribe<T> |
RxJavaSingleExecutionHook.onSubscribeStart(Single<? extends T> singleInstance,
Observable.OnSubscribe<T> onSubscribe)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Func1<Observable.OnSubscribe,Observable.OnSubscribe> |
RxJavaHooks.getOnObservableCreate()
Returns the current Observable onCreate hook function or null if it is
set to the default pass-through.
|
static Func1<Observable.OnSubscribe,Observable.OnSubscribe> |
RxJavaHooks.getOnObservableCreate()
Returns the current Observable onCreate hook function or null if it is
set to the default pass-through.
|
static Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe> |
RxJavaHooks.getOnObservableStart()
Returns the current Observable onStart hook function or null if it is
set to the default pass-through.
|
static Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe> |
RxJavaHooks.getOnObservableStart()
Returns the current Observable onStart hook function or null if it is
set to the default pass-through.
|
static Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe> |
RxJavaHooks.getOnSingleStart()
Returns the current Single onStart hook function or null if it is
set to the default pass-through.
|
static Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe> |
RxJavaHooks.getOnSingleStart()
Returns the current Single onStart hook function or null if it is
set to the default pass-through.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable.OnSubscribe<T> |
RxJavaHooks.onCreate(Observable.OnSubscribe<T> onSubscribe)
Hook to call when an Observable is created.
|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onCreate(Observable.OnSubscribe<T> f)
Deprecated.
|
static <T> Observable.OnSubscribe<T> |
RxJavaHooks.onObservableStart(Observable<T> instance,
Observable.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
static <T> Observable.OnSubscribe<T> |
RxJavaHooks.onSingleStart(Single<T> instance,
Observable.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance,
Observable.OnSubscribe<T> onSubscribe)
Deprecated.
|
<T> Observable.OnSubscribe<T> |
RxJavaSingleExecutionHook.onSubscribeStart(Single<? extends T> singleInstance,
Observable.OnSubscribe<T> onSubscribe)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaHooks.setOnObservableCreate(Func1<Observable.OnSubscribe,Observable.OnSubscribe> onObservableCreate)
Sets the Observable onCreate hook function unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnObservableCreate(Func1<Observable.OnSubscribe,Observable.OnSubscribe> onObservableCreate)
Sets the Observable onCreate hook function unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnObservableStart(Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe> onObservableStart)
Sets the hook function that is called when a subscriber subscribes to a Observable
unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnObservableStart(Func2<Observable,Observable.OnSubscribe,Observable.OnSubscribe> onObservableStart)
Sets the hook function that is called when a subscriber subscribes to a Observable
unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnSingleStart(Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe> onSingleStart)
Sets the hook function that is called when a subscriber subscribes to a Single
unless a lockdown is in effect.
|
static void |
RxJavaHooks.setOnSingleStart(Func2<Single,Observable.OnSubscribe,Observable.OnSubscribe> onSingleStart)
Sets the hook function that is called when a subscriber subscribes to a Single
unless a lockdown is in effect.
|
Constructor and Description |
---|
AsyncSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
BehaviorSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
PublishSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state) |
Subject(Observable.OnSubscribe<R> onSubscribe) |
TestSubject(Observable.OnSubscribe<T> onSubscribe,
rx.subjects.SubjectSubscriptionManager<T> state,
TestScheduler scheduler) |
Copyright © 2023. All rights reserved.