Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.functions |
Functional interfaces of functions and actions of arity 0 to 9 and related
utility classes.
|
rx.observables |
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
Completable.CompletableOnSubscribe
Callback used for building deferred computations that takes a CompletableSubscriber.
|
static interface |
Observable.OnSubscribe<T>
Invoked when Observable.subscribe is called.
|
static interface |
Single.OnSubscribe<T>
Invoked when Single.execute is called.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Action0
A zero-argument action.
|
interface |
Action1<T>
A one-argument action.
|
interface |
Action2<T1,T2>
A two-argument action.
|
interface |
Action3<T1,T2,T3>
A three-argument action.
|
interface |
Action4<T1,T2,T3,T4>
A four-argument action.
|
interface |
Action5<T1,T2,T3,T4,T5>
A five-argument action.
|
interface |
Action6<T1,T2,T3,T4,T5,T6>
A six-argument action.
|
interface |
Action7<T1,T2,T3,T4,T5,T6,T7>
A seven-argument action.
|
interface |
Action8<T1,T2,T3,T4,T5,T6,T7,T8>
An eight-argument action.
|
interface |
Action9<T1,T2,T3,T4,T5,T6,T7,T8,T9>
A nine-argument action.
|
interface |
ActionN
A vector-argument action.
|
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. |
Copyright © 2023. All rights reserved.