Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.disposables |
Default implementations for Disposable-based resource management
(Disposable container types) and utility classes to construct
Disposables from callbacks and other types.
|
io.reactivex.flowables |
Classes supporting the Flowable base reactive class:
ConnectableFlowable and
GroupedFlowable . |
io.reactivex.internal.disposables | |
io.reactivex.internal.fuseable |
Base interfaces and types for supporting operator-fusion.
|
io.reactivex.internal.observers | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.queue | |
io.reactivex.internal.schedulers | |
io.reactivex.internal.subscriptions | |
io.reactivex.observables |
Classes supporting the Observable base reactive class:
ConnectableObservable and
GroupedObservable . |
io.reactivex.plugins |
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. |
io.reactivex.processors |
Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
|
io.reactivex.subjects |
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
|
Modifier and Type | Method and Description |
---|---|
Throwable |
Completable.blockingGet()
Subscribes to this Completable instance and blocks until it terminates, then returns null or
the emitted exception if any.
|
Throwable |
Completable.blockingGet(long timeout,
TimeUnit unit)
Subscribes to this Completable instance and blocks until it terminates or the specified timeout
elapses, then returns null for normal termination or the emitted exception if any.
|
Throwable |
Notification.getError()
Returns the container Throwable error if this notification is an onError
signal, null otherwise.
|
T |
Notification.getValue()
Returns the contained value if this notification is an onNext
signal, null otherwise.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
ObservableEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
MaybeEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
FlowableEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
CompletableEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
SingleEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous Disposable
or Cancellable will be disposed/cancelled.
|
void |
ObservableEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
MaybeEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
FlowableEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
void |
CompletableEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous
Disposable
or Cancellable will be disposed/cancelled. |
Modifier and Type | Method and Description |
---|---|
Disposable |
SerialDisposable.get()
Returns the currently contained Disposable or null if this container is empty.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SerialDisposable.replace(Disposable next)
Atomically: set the next disposable on this container but don't dispose the previous
one (if any) or dispose next if the container has been disposed.
|
boolean |
SerialDisposable.set(Disposable next)
Atomically: set the next disposable on this container and dispose the previous
one (if any) or dispose next if the container has been disposed.
|
Constructor and Description |
---|
SerialDisposable(Disposable initialDisposable)
Constructs a SerialDisposable with the given initial Disposable instance.
|
Modifier and Type | Method and Description |
---|---|
K |
GroupedFlowable.getKey()
Returns the key that identifies the group of items emitted by this
GroupedFlowable . |
Constructor and Description |
---|
GroupedFlowable(K key)
Constructs a GroupedFlowable with the given key.
|
Modifier and Type | Method and Description |
---|---|
Object |
EmptyDisposable.poll() |
Modifier and Type | Method and Description |
---|---|
T |
SimpleQueue.poll()
Tries to dequeue a value (non-null) or returns null if
the queue is empty.
|
T |
SimplePlainQueue.poll() |
Modifier and Type | Method and Description |
---|---|
T |
DeferredScalarDisposable.poll() |
Modifier and Type | Method and Description |
---|---|
GroupedFlowable<K,V> |
FlowableGroupBy.GroupBySubscriber.poll() |
Modifier and Type | Method and Description |
---|---|
T |
ObservableScalarXMap.ScalarDisposable.poll() |
Modifier and Type | Method and Description |
---|---|
T |
SpscLinkedArrayQueue.poll()
Tries to dequeue a value (non-null) or returns null if
the queue is empty.
|
E |
SpscArrayQueue.poll() |
T |
MpscLinkedQueue.poll()
Tries to dequeue a value (non-null) or returns null if
the queue is empty.
|
Modifier and Type | Method and Description |
---|---|
ScheduledRunnable |
NewThreadWorker.scheduleActual(Runnable run,
long delayTime,
TimeUnit unit,
DisposableContainer parent)
Wraps the given runnable into a ScheduledRunnable and schedules it
on the underlying ScheduledExecutorService.
|
Modifier and Type | Method and Description |
---|---|
T |
ScalarSubscription.poll() |
Object |
EmptySubscription.poll() |
T |
DeferredScalarSubscription.poll() |
Modifier and Type | Method and Description |
---|---|
K |
GroupedObservable.getKey()
Returns the key that identifies the group of items emitted by this
GroupedObservable . |
Constructor and Description |
---|
GroupedObservable(K key)
Constructs a GroupedObservable with the given key.
|
Modifier and Type | Method and Description |
---|---|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getComputationSchedulerHandler()
Returns the current hook function.
|
static Consumer<? super Throwable> |
RxJavaPlugins.getErrorHandler()
Returns the a hook consumer.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitComputationSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitIoSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitNewThreadSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitSingleSchedulerHandler()
Returns the current hook function.
|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getIoSchedulerHandler()
Returns the current hook function.
|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getNewThreadSchedulerHandler()
Returns the current hook function.
|
static BooleanSupplier |
RxJavaPlugins.getOnBeforeBlocking()
Returns the current blocking handler or null if no custom handler
is set.
|
static Function<? super Completable,? extends Completable> |
RxJavaPlugins.getOnCompletableAssembly()
Returns the current hook function.
|
static BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> |
RxJavaPlugins.getOnCompletableSubscribe()
Returns the current hook function.
|
static Function<? super ConnectableFlowable,? extends ConnectableFlowable> |
RxJavaPlugins.getOnConnectableFlowableAssembly()
Returns the current hook function.
|
static Function<? super ConnectableObservable,? extends ConnectableObservable> |
RxJavaPlugins.getOnConnectableObservableAssembly()
Returns the current hook function.
|
static Function<? super Flowable,? extends Flowable> |
RxJavaPlugins.getOnFlowableAssembly()
Returns the current hook function.
|
static BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber> |
RxJavaPlugins.getOnFlowableSubscribe()
Returns the current hook function.
|
static Function<? super Maybe,? extends Maybe> |
RxJavaPlugins.getOnMaybeAssembly()
Returns the current hook function.
|
static BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver> |
RxJavaPlugins.getOnMaybeSubscribe()
Returns the current hook function.
|
static Function<? super Observable,? extends Observable> |
RxJavaPlugins.getOnObservableAssembly()
Returns the current hook function.
|
static BiFunction<? super Observable,? super Observer,? extends Observer> |
RxJavaPlugins.getOnObservableSubscribe()
Returns the current hook function.
|
static Function<? super ParallelFlowable,? extends ParallelFlowable> |
RxJavaPlugins.getOnParallelAssembly()
Returns the current hook function.
|
static Function<? super Single,? extends Single> |
RxJavaPlugins.getOnSingleAssembly()
Returns the current hook function.
|
static BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> |
RxJavaPlugins.getOnSingleSubscribe()
Returns the current hook function.
|
static Function<? super Runnable,? extends Runnable> |
RxJavaPlugins.getScheduleHandler()
Returns the current hook function.
|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getSingleSchedulerHandler()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setComputationSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setErrorHandler(Consumer<? super Throwable> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitComputationSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitIoSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitNewThreadSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitSingleSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setIoSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setNewThreadSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnBeforeBlocking(BooleanSupplier handler)
Set the handler that is called when an operator attempts a blocking
await; the handler should return true to prevent the blocking
and to signal an IllegalStateException instead.
|
static void |
RxJavaPlugins.setOnCompletableAssembly(Function<? super Completable,? extends Completable> onCompletableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnCompletableSubscribe(BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> onCompletableSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnConnectableFlowableAssembly(Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnConnectableObservableAssembly(Function<? super ConnectableObservable,? extends ConnectableObservable> onConnectableObservableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnFlowableAssembly(Function<? super Flowable,? extends Flowable> onFlowableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnFlowableSubscribe(BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber> onFlowableSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnMaybeAssembly(Function<? super Maybe,? extends Maybe> onMaybeAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnMaybeSubscribe(BiFunction<? super Maybe,MaybeObserver,? extends MaybeObserver> onMaybeSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnObservableAssembly(Function<? super Observable,? extends Observable> onObservableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnObservableSubscribe(BiFunction<? super Observable,? super Observer,? extends Observer> onObservableSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnParallelAssembly(Function<? super ParallelFlowable,? extends ParallelFlowable> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnSingleAssembly(Function<? super Single,? extends Single> onSingleAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnSingleSubscribe(BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> onSingleSubscribe)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setScheduleHandler(Function<? super Runnable,? extends Runnable> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setSingleSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
Modifier and Type | Method and Description |
---|---|
Throwable |
UnicastProcessor.getThrowable() |
Throwable |
ReplayProcessor.getThrowable() |
Throwable |
PublishProcessor.getThrowable() |
abstract Throwable |
FlowableProcessor.getThrowable()
Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor
hasn't terminated yet.
|
Throwable |
BehaviorProcessor.getThrowable() |
Throwable |
AsyncProcessor.getThrowable() |
T |
BehaviorProcessor.getValue()
Returns a single value the BehaviorProcessor currently has or null if no such value exists.
|
T |
AsyncProcessor.getValue()
Returns a single value this processor currently has or null if no such value exists.
|
Modifier and Type | Method and Description |
---|---|
Throwable |
UnicastSubject.getThrowable() |
abstract Throwable |
Subject.getThrowable()
Returns the error that caused the Subject to terminate or null if the Subject
hasn't terminated yet.
|
Throwable |
SingleSubject.getThrowable()
Returns the terminal error if this SingleSubject has been terminated with an error, null otherwise.
|
Throwable |
ReplaySubject.getThrowable() |
Throwable |
PublishSubject.getThrowable() |
Throwable |
MaybeSubject.getThrowable()
Returns the terminal error if this MaybeSubject has been terminated with an error, null otherwise.
|
Throwable |
CompletableSubject.getThrowable()
Returns the terminal error if this CompletableSubject has been terminated with an error, null otherwise.
|
Throwable |
BehaviorSubject.getThrowable() |
T |
SingleSubject.getValue()
Returns the success value if this SingleSubject was terminated with a success value.
|
T |
ReplaySubject.getValue()
Returns a single value the Subject currently has or null if no such value exists.
|
T |
MaybeSubject.getValue()
Returns the success value if this MaybeSubject was terminated with a success value.
|
T |
BehaviorSubject.getValue()
Returns a single value the Subject currently has or null if no such value exists.
|
T |
AsyncSubject.getValue()
Returns a single value the Subject currently has or null if no such value exists.
|
Copyright © 2019. All rights reserved.