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 |
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 |
FlowableEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be disposed/cancelled.
|
void |
SingleEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
|
void |
CompletableEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be disposed/cancelled.
|
void |
MaybeEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
|
void |
ObservableEmitter.setCancellable(Cancellable c)
Sets a Cancellable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
|
void |
FlowableEmitter.setDisposable(Disposable s)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be disposed/cancelled.
|
void |
SingleEmitter.setDisposable(Disposable s)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
|
void |
CompletableEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be disposed/cancelled.
|
void |
MaybeEmitter.setDisposable(Disposable s)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/cancelled.
|
void |
ObservableEmitter.setDisposable(Disposable d)
Sets a Disposable on this emitter; any previous Disposable
or Cancellation will be unsubscribed/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 |
SimplePlainQueue.poll() |
T |
SimpleQueue.poll()
Tries to dequeue a value (non-null) or returns null if
the queue is empty.
|
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 |
---|---|
E |
SpscArrayQueue.poll() |
T |
MpscLinkedQueue.poll()
Tries to dequeue a value (non-null) or returns null if
the queue is empty.
|
T |
SpscLinkedArrayQueue.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 |
ReplayProcessor.getThrowable() |
Throwable |
BehaviorProcessor.getThrowable() |
Throwable |
PublishProcessor.getThrowable() |
Throwable |
UnicastProcessor.getThrowable() |
Throwable |
AsyncProcessor.getThrowable() |
abstract Throwable |
FlowableProcessor.getThrowable()
Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor
hasn't terminated yet.
|
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 |
ReplaySubject.getThrowable() |
Throwable |
PublishSubject.getThrowable() |
Throwable |
CompletableSubject.getThrowable()
Returns the terminal error if this CompletableSubject has been terminated with an error, null otherwise.
|
Throwable |
SingleSubject.getThrowable()
Returns the terminal error if this SingleSubject has been terminated with an error, null otherwise.
|
abstract Throwable |
Subject.getThrowable()
Returns the error that caused the Subject to terminate or null if the Subject
hasn't terminated yet.
|
Throwable |
MaybeSubject.getThrowable()
Returns the terminal error if this MaybeSubject has been terminated with an error, null otherwise.
|
Throwable |
BehaviorSubject.getThrowable() |
Throwable |
UnicastSubject.getThrowable() |
T |
ReplaySubject.getValue()
Returns a single value the Subject currently has or null if no such value exists.
|
T |
SingleSubject.getValue()
Returns the success value if this SingleSubject was terminated with a success value.
|
T |
AsyncSubject.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.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.