Uses of Class
io.reactivex.rxjava3.annotations.Nullable
-
Packages that use Nullable Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.disposables Default implementations forDisposable
-based resource management (Disposable
container types) and utility classes to constructDisposables
from callbacks and other types.io.reactivex.rxjava3.flowables Classes supporting the Flowable base reactive class:ConnectableFlowable
andGroupedFlowable
.io.reactivex.rxjava3.internal.disposables io.reactivex.rxjava3.internal.jdk8 io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.single io.reactivex.rxjava3.internal.queue io.reactivex.rxjava3.internal.schedulers io.reactivex.rxjava3.internal.subscriptions io.reactivex.rxjava3.observables Classes supporting the Observable base reactive class:ConnectableObservable
andGroupedObservable
.io.reactivex.rxjava3.observers Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and theTestObserver
that allows unit testingObservable
-,Single
-,Maybe
- andCompletable
-based flows.io.reactivex.rxjava3.operators Classes and interfaces for writing advanced operators within and outside RxJava.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
.io.reactivex.rxjava3.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. -
-
Uses of Nullable in io.reactivex.rxjava3.core
Fields in io.reactivex.rxjava3.core with annotations of type Nullable Modifier and Type Field Description (package private) @Nullable java.lang.Thread
Scheduler.DisposeTask. runner
Methods in io.reactivex.rxjava3.core with annotations of type Nullable Modifier and Type Method Description T
Maybe. blockingGet()
Waits in a blocking fashion until the currentMaybe
signals a success value (which is returned),null
if completed or an exception (which is propagated).@Nullable java.lang.Throwable
Notification. getError()
Returns the containerThrowable
error if this notification is anonError
signal, null otherwise.T
Notification. getValue()
Returns the contained value if this notification is anonNext
signal, null otherwise.Method parameters in io.reactivex.rxjava3.core with annotations of type Nullable Modifier and Type Method Description @NonNull java.util.concurrent.CompletionStage<T>
Flowable. firstStage(@NonNull T defaultItem)
Signals the first upstream item (or the default item if the upstream is empty) via aCompletionStage
.@NonNull java.util.concurrent.CompletionStage<T>
Observable. firstStage(@NonNull T defaultItem)
Signals the first upstream item (or the default item if the upstream is empty) via aCompletionStage
.@NonNull java.util.concurrent.CompletionStage<T>
Flowable. lastStage(@NonNull T defaultItem)
Signals the last upstream item (or the default item if the upstream is empty) via aCompletionStage
.@NonNull java.util.concurrent.CompletionStage<T>
Observable. lastStage(@NonNull T defaultItem)
Signals the last upstream item (or the default item if the upstream is empty) via aCompletionStage
.@NonNull Flowable<T>
Flowable. onBackpressureBuffer(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy)
Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.@NonNull Flowable<T>
Flowable. onBackpressureBuffer(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy, @NonNull Consumer<? super @NonNull T> onDropped)
Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.void
CompletableEmitter. setCancellable(@Nullable Cancellable c)
Sets a Cancellable on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
FlowableEmitter. setCancellable(@Nullable Cancellable c)
Sets aCancellable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
MaybeEmitter. setCancellable(@Nullable Cancellable c)
Sets aCancellable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
ObservableEmitter. setCancellable(@Nullable Cancellable c)
Sets aCancellable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
SingleEmitter. setCancellable(@Nullable Cancellable c)
Sets a Cancellable on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
CompletableEmitter. setDisposable(@Nullable Disposable d)
Sets a Disposable on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
FlowableEmitter. setDisposable(@Nullable Disposable d)
Sets a Disposable on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
MaybeEmitter. setDisposable(@Nullable Disposable d)
Sets aDisposable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
ObservableEmitter. setDisposable(@Nullable Disposable d)
Sets aDisposable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.void
SingleEmitter. setDisposable(@Nullable Disposable d)
Sets aDisposable
on this emitter; any previousDisposable
orCancellable
will be disposed/cancelled.@NonNull java.util.concurrent.CompletionStage<T>
Flowable. singleStage(@NonNull T defaultItem)
Signals the only expected upstream item (or the default item if the upstream is empty) or signalsIllegalArgumentException
if the upstream has more than one item via aCompletionStage
.@NonNull java.util.concurrent.CompletionStage<T>
Observable. singleStage(@NonNull T defaultItem)
Signals the only expected upstream item (or the default item if the upstream is empty) or signalsIllegalArgumentException
if the upstream has more than one item via aCompletionStage
.private @NonNull Observable<T>
Observable. timeout0(long timeout, @NonNull java.util.concurrent.TimeUnit unit, @Nullable ObservableSource<? extends @NonNull T> fallback, @NonNull Scheduler scheduler)
private <U,V>
@NonNull Observable<T>Observable. timeout0(@NonNull ObservableSource<U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T,? extends ObservableSource<V>> itemTimeoutIndicator, @Nullable ObservableSource<? extends @NonNull T> fallback)
@NonNull java.util.concurrent.CompletionStage<T>
Maybe. toCompletionStage(@NonNull T defaultItem)
Signals the upstream success item (or the default item if the upstream is empty) via aCompletionStage
.Constructor parameters in io.reactivex.rxjava3.core with annotations of type Nullable Constructor Description Notification(@Nullable java.lang.Object value)
Not meant to be implemented externally. -
Uses of Nullable in io.reactivex.rxjava3.disposables
Methods in io.reactivex.rxjava3.disposables with annotations of type Nullable Modifier and Type Method Description @Nullable Disposable
SerialDisposable. get()
Returns the currently contained Disposable or null if this container is empty.Method parameters in io.reactivex.rxjava3.disposables with annotations of type Nullable Modifier and Type Method Description (package private) void
CompositeDisposable. dispose(@Nullable OpenHashSet<Disposable> set)
Dispose the contents of theOpenHashSet
by suppressing non-fatalThrowable
s till the end.boolean
SerialDisposable. replace(@Nullable 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(@Nullable 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 parameters in io.reactivex.rxjava3.disposables with annotations of type Nullable Constructor Description SerialDisposable(@Nullable Disposable initialDisposable)
Constructs a SerialDisposable with the given initial Disposable instance. -
Uses of Nullable in io.reactivex.rxjava3.flowables
Methods in io.reactivex.rxjava3.flowables with annotations of type Nullable Modifier and Type Method Description K
GroupedFlowable. getKey()
Returns the key that identifies the group of items emitted by thisGroupedFlowable
.Constructor parameters in io.reactivex.rxjava3.flowables with annotations of type Nullable Constructor Description GroupedFlowable(K key)
Constructs a GroupedFlowable with the given key. -
Uses of Nullable in io.reactivex.rxjava3.internal.disposables
Methods in io.reactivex.rxjava3.internal.disposables with annotations of type Nullable Modifier and Type Method Description @Nullable java.lang.Object
EmptyDisposable. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.jdk8
Methods in io.reactivex.rxjava3.internal.jdk8 with annotations of type Nullable Modifier and Type Method Description T
FlowableFromStream.AbstractStreamSubscription. poll()
R
MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver. poll()
R
MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver. poll()
T
ObservableFromStream.StreamDisposable. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.observers
Methods in io.reactivex.rxjava3.internal.observers with annotations of type Nullable Modifier and Type Method Description T
DeferredScalarDisposable. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable with annotations of type Nullable Modifier and Type Field Description (package private) @Nullable org.reactivestreams.Publisher<? extends T>[]
FlowableCombineLatest. array
(package private) @Nullable java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends T>>
FlowableCombineLatest. iterable
(package private) @Nullable org.reactivestreams.Publisher<?>[]
FlowableWithLatestFromMany. otherArray
(package private) @Nullable java.lang.Iterable<? extends org.reactivestreams.Publisher<?>>
FlowableWithLatestFromMany. otherIterable
Methods in io.reactivex.rxjava3.internal.operators.flowable with annotations of type Nullable Modifier and Type Method Description R
FlowableCombineLatest.CombineLatestCoordinator. poll()
T
FlowableDistinct.DistinctSubscriber. poll()
T
FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber. poll()
T
FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber. poll()
T
FlowableDoAfterNext.DoAfterConditionalSubscriber. poll()
T
FlowableDoAfterNext.DoAfterSubscriber. poll()
T
FlowableDoFinally.DoFinallyConditionalSubscriber. poll()
T
FlowableDoFinally.DoFinallySubscriber. poll()
T
FlowableDoOnEach.DoOnEachConditionalSubscriber. poll()
T
FlowableDoOnEach.DoOnEachSubscriber. poll()
T
FlowableFilter.FilterConditionalSubscriber. poll()
T
FlowableFilter.FilterSubscriber. poll()
T
FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber. poll()
R
FlowableFlattenIterable.FlattenIterableSubscriber. poll()
T
FlowableFromArray.BaseArraySubscription. poll()
T
FlowableFromIterable.BaseRangeSubscription. poll()
T
FlowableGroupBy.State. poll()
T
FlowableIgnoreElements.IgnoreElementsSubscriber. poll()
U
FlowableMap.MapConditionalSubscriber. poll()
U
FlowableMap.MapSubscriber. poll()
T
FlowableObserveOn.ObserveOnConditionalSubscriber. poll()
T
FlowableObserveOn.ObserveOnSubscriber. poll()
T
FlowableOnBackpressureBuffer.BackpressureBufferSubscriber. poll()
@Nullable java.lang.Integer
FlowableRange.BaseRangeSubscription. poll()
@Nullable java.lang.Long
FlowableRangeLong.BaseRangeSubscription. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.operators.maybe
Methods in io.reactivex.rxjava3.internal.operators.maybe with annotations of type Nullable Modifier and Type Method Description R
MaybeFlatMapIterableFlowable.FlatMapIterableObserver. poll()
R
MaybeFlatMapIterableObservable.FlatMapIterableObserver. poll()
T
MaybeMergeArray.ClqSimpleQueue. poll()
T
MaybeMergeArray.MergeMaybeObserver. poll()
T
MaybeMergeArray.MpscFillOnceSimpleQueue. poll()
T
MaybeMergeArray.SimpleQueueWithConsumerIndex. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable with annotations of type Nullable Modifier and Type Field Description (package private) @Nullable ObservableSource<?>[]
ObservableWithLatestFromMany. otherArray
(package private) @Nullable java.lang.Iterable<? extends ObservableSource<?>>
ObservableWithLatestFromMany. otherIterable
Methods in io.reactivex.rxjava3.internal.operators.observable with annotations of type Nullable Modifier and Type Method Description T
ObservableDistinct.DistinctObserver. poll()
T
ObservableDistinctUntilChanged.DistinctUntilChangedObserver. poll()
T
ObservableDoAfterNext.DoAfterObserver. poll()
T
ObservableDoFinally.DoFinallyObserver. poll()
T
ObservableFilter.FilterObserver. poll()
T
ObservableFlatMapCompletable.FlatMapCompletableMainObserver. poll()
T
ObservableFromArray.FromArrayDisposable. poll()
T
ObservableFromIterable.FromIterableDisposable. poll()
U
ObservableMap.MapObserver. poll()
T
ObservableObserveOn.ObserveOnObserver. poll()
@Nullable java.lang.Integer
ObservableRange.RangeDisposable. poll()
@Nullable java.lang.Long
ObservableRangeLong.RangeDisposable. poll()
T
ObservableScalarXMap.ScalarDisposable. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.operators.single
Methods in io.reactivex.rxjava3.internal.operators.single with annotations of type Nullable Modifier and Type Method Description R
SingleFlatMapIterableFlowable.FlatMapIterableObserver. poll()
R
SingleFlatMapIterableObservable.FlatMapIterableObserver. poll()
-
Uses of Nullable in io.reactivex.rxjava3.internal.queue
Methods in io.reactivex.rxjava3.internal.queue with annotations of type Nullable Modifier and Type Method Description T
MpscLinkedQueue. poll()
Tries to dequeue a value (non-null) or returns null if the queue is empty. -
Uses of Nullable in io.reactivex.rxjava3.internal.schedulers
Method parameters in io.reactivex.rxjava3.internal.schedulers with annotations of type Nullable Modifier and Type Method Description @NonNull ScheduledRunnable
NewThreadWorker. scheduleActual(java.lang.Runnable run, long delayTime, @NonNull java.util.concurrent.TimeUnit unit, @Nullable DisposableContainer parent)
Wraps and returns the given runnable into a ScheduledRunnable and schedules it on the underlying ScheduledExecutorService. -
Uses of Nullable in io.reactivex.rxjava3.internal.subscriptions
Methods in io.reactivex.rxjava3.internal.subscriptions with annotations of type Nullable Modifier and Type Method Description T
DeferredScalarSubscription. poll()
@Nullable java.lang.Object
EmptySubscription. poll()
T
ScalarSubscription. poll()
-
Uses of Nullable in io.reactivex.rxjava3.observables
Methods in io.reactivex.rxjava3.observables with annotations of type Nullable Modifier and Type Method Description K
GroupedObservable. getKey()
Returns the key that identifies the group of items emitted by thisGroupedObservable
.Constructor parameters in io.reactivex.rxjava3.observables with annotations of type Nullable Constructor Description GroupedObservable(K key)
Constructs a GroupedObservable with the given key. -
Uses of Nullable in io.reactivex.rxjava3.observers
Method parameters in io.reactivex.rxjava3.observers with annotations of type Nullable Modifier and Type Method Description static @NonNull java.lang.String
BaseTestConsumer. valueAndClass(@Nullable java.lang.Object o)
Appends the class name to a non-null
value or returns"null"
.U
BaseTestConsumer. withTag(@Nullable java.lang.CharSequence tag)
Set the tag displayed along with an assertion failure's other state information. -
Uses of Nullable in io.reactivex.rxjava3.operators
Methods in io.reactivex.rxjava3.operators with annotations of type Nullable Modifier and Type Method Description T
SpscLinkedArrayQueue. peek()
Returns the next element in this queue without removing it ornull
if this queue is emptyT
SimplePlainQueue. poll()
T
SimpleQueue. poll()
Tries to dequeue a value (non-null) or returns null if the queue is empty.E
SpscArrayQueue. poll()
T
SpscLinkedArrayQueue. poll()
Tries to dequeue a value (non-null) or returns null if the queue is empty. -
Uses of Nullable in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with annotations of type Nullable Modifier and Type Field Description (package private) static @Nullable Consumer<? super java.lang.Throwable>
RxJavaPlugins. errorHandler
(package private) static @Nullable BooleanSupplier
RxJavaPlugins. onBeforeBlocking
(package private) static @Nullable Function<? super Completable,? extends Completable>
RxJavaPlugins. onCompletableAssembly
(package private) static @Nullable BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver>
RxJavaPlugins. onCompletableSubscribe
(package private) static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. onComputationHandler
(package private) static @Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable>
RxJavaPlugins. onConnectableFlowableAssembly
(package private) static @Nullable Function<? super ConnectableObservable,? extends ConnectableObservable>
RxJavaPlugins. onConnectableObservableAssembly
(package private) static @Nullable Function<? super Flowable,? extends Flowable>
RxJavaPlugins. onFlowableAssembly
(package private) static @Nullable BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber>
RxJavaPlugins. onFlowableSubscribe
(package private) static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. onInitComputationHandler
(package private) static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. onInitIoHandler
(package private) static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. onInitNewThreadHandler
(package private) static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. onInitSingleHandler
(package private) static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. onIoHandler
(package private) static @Nullable Function<? super Maybe,? extends Maybe>
RxJavaPlugins. onMaybeAssembly
(package private) static @Nullable BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver>
RxJavaPlugins. onMaybeSubscribe
(package private) static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. onNewThreadHandler
(package private) static @Nullable Function<? super Observable,? extends Observable>
RxJavaPlugins. onObservableAssembly
(package private) static @Nullable BiFunction<? super Observable,? super Observer,? extends Observer>
RxJavaPlugins. onObservableSubscribe
(package private) static @Nullable Function<? super ParallelFlowable,? extends ParallelFlowable>
RxJavaPlugins. onParallelAssembly
(package private) static @Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]>
RxJavaPlugins. onParallelSubscribe
(package private) static @Nullable Function<? super java.lang.Runnable,? extends java.lang.Runnable>
RxJavaPlugins. onScheduleHandler
(package private) static @Nullable Function<? super Single,? extends Single>
RxJavaPlugins. onSingleAssembly
(package private) static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. onSingleHandler
(package private) static @Nullable BiFunction<? super Single,? super SingleObserver,? extends SingleObserver>
RxJavaPlugins. onSingleSubscribe
Methods in io.reactivex.rxjava3.plugins with annotations of type Nullable Modifier and Type Method Description static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. getComputationSchedulerHandler()
Returns the current hook function.static @Nullable Consumer<? super java.lang.Throwable>
RxJavaPlugins. getErrorHandler()
Returns the a hook consumer.static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. getInitComputationSchedulerHandler()
Returns the current hook function.static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. getInitIoSchedulerHandler()
Returns the current hook function.static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. getInitNewThreadSchedulerHandler()
Returns the current hook function.static @Nullable Function<? super Supplier<Scheduler>,? extends Scheduler>
RxJavaPlugins. getInitSingleSchedulerHandler()
Returns the current hook function.static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. getIoSchedulerHandler()
Returns the current hook function.static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. getNewThreadSchedulerHandler()
Returns the current hook function.static @Nullable BooleanSupplier
RxJavaPlugins. getOnBeforeBlocking()
Returns the current blocking handler or null if no custom handler is set.static @Nullable Function<? super Completable,? extends Completable>
RxJavaPlugins. getOnCompletableAssembly()
Returns the current hook function.static @Nullable BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver>
RxJavaPlugins. getOnCompletableSubscribe()
Returns the current hook function.static @Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable>
RxJavaPlugins. getOnConnectableFlowableAssembly()
Returns the current hook function.static @Nullable Function<? super ConnectableObservable,? extends ConnectableObservable>
RxJavaPlugins. getOnConnectableObservableAssembly()
Returns the current hook function.static @Nullable Function<? super Flowable,? extends Flowable>
RxJavaPlugins. getOnFlowableAssembly()
Returns the current hook function.static @Nullable BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber>
RxJavaPlugins. getOnFlowableSubscribe()
Returns the current hook function.static @Nullable Function<? super Maybe,? extends Maybe>
RxJavaPlugins. getOnMaybeAssembly()
Returns the current hook function.static @Nullable BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver>
RxJavaPlugins. getOnMaybeSubscribe()
Returns the current hook function.static @Nullable Function<? super Observable,? extends Observable>
RxJavaPlugins. getOnObservableAssembly()
Returns the current hook function.static @Nullable BiFunction<? super Observable,? super Observer,? extends Observer>
RxJavaPlugins. getOnObservableSubscribe()
Returns the current hook function.static @Nullable Function<? super ParallelFlowable,? extends ParallelFlowable>
RxJavaPlugins. getOnParallelAssembly()
Returns the current hook function.static @Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]>
RxJavaPlugins. getOnParallelSubscribe()
Returns the current hook function.static @Nullable Function<? super Single,? extends Single>
RxJavaPlugins. getOnSingleAssembly()
Returns the current hook function.static @Nullable BiFunction<? super Single,? super SingleObserver,? extends SingleObserver>
RxJavaPlugins. getOnSingleSubscribe()
Returns the current hook function.static @Nullable Function<? super java.lang.Runnable,? extends java.lang.Runnable>
RxJavaPlugins. getScheduleHandler()
Returns the current hook function.static @Nullable Function<? super Scheduler,? extends Scheduler>
RxJavaPlugins. getSingleSchedulerHandler()
Returns the current hook function.Method parameters in io.reactivex.rxjava3.plugins with annotations of type Nullable Modifier and Type Method Description static void
RxJavaPlugins. setComputationSchedulerHandler(@Nullable Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setErrorHandler(@Nullable Consumer<? super java.lang.Throwable> handler)
Sets the specific hook function.static void
RxJavaPlugins. setInitComputationSchedulerHandler(@Nullable Function<? super Supplier<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setInitIoSchedulerHandler(@Nullable Function<? super Supplier<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setInitNewThreadSchedulerHandler(@Nullable Function<? super Supplier<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setInitSingleSchedulerHandler(@Nullable Function<? super Supplier<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setIoSchedulerHandler(@Nullable Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setNewThreadSchedulerHandler(@Nullable Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.static void
RxJavaPlugins. setOnBeforeBlocking(@Nullable 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(@Nullable Function<? super Completable,? extends Completable> onCompletableAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnCompletableSubscribe(@Nullable BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver> onCompletableSubscribe)
Sets the specific hook function.static void
RxJavaPlugins. setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnConnectableObservableAssembly(@Nullable Function<? super ConnectableObservable,? extends ConnectableObservable> onConnectableObservableAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnFlowableAssembly(@Nullable Function<? super Flowable,? extends Flowable> onFlowableAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnFlowableSubscribe(@Nullable BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber> onFlowableSubscribe)
Sets the specific hook function.static void
RxJavaPlugins. setOnMaybeAssembly(@Nullable Function<? super Maybe,? extends Maybe> onMaybeAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnMaybeSubscribe(@Nullable BiFunction<? super Maybe,@NonNull MaybeObserver,? extends MaybeObserver> onMaybeSubscribe)
Sets the specific hook function.static void
RxJavaPlugins. setOnObservableAssembly(@Nullable Function<? super Observable,? extends Observable> onObservableAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnObservableSubscribe(@Nullable BiFunction<? super Observable,? super Observer,? extends Observer> onObservableSubscribe)
Sets the specific hook function.static void
RxJavaPlugins. setOnParallelAssembly(@Nullable Function<? super ParallelFlowable,? extends ParallelFlowable> handler)
Sets the specific hook function.static void
RxJavaPlugins. setOnParallelSubscribe(@Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]> handler)
Sets the specific hook function.static void
RxJavaPlugins. setOnSingleAssembly(@Nullable Function<? super Single,? extends Single> onSingleAssembly)
Sets the specific hook function.static void
RxJavaPlugins. setOnSingleSubscribe(@Nullable BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> onSingleSubscribe)
Sets the specific hook function.static void
RxJavaPlugins. setScheduleHandler(@Nullable Function<? super java.lang.Runnable,? extends java.lang.Runnable> handler)
Sets the specific hook function.static void
RxJavaPlugins. setSingleSchedulerHandler(@Nullable Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function. -
Uses of Nullable in io.reactivex.rxjava3.processors
Methods in io.reactivex.rxjava3.processors with annotations of type Nullable Modifier and Type Method Description @Nullable java.lang.Throwable
AsyncProcessor. getThrowable()
@Nullable java.lang.Throwable
BehaviorProcessor. getThrowable()
abstract @Nullable java.lang.Throwable
FlowableProcessor. getThrowable()
Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet.@Nullable java.lang.Throwable
PublishProcessor. getThrowable()
@Nullable java.lang.Throwable
ReplayProcessor. getThrowable()
@Nullable java.lang.Throwable
SerializedProcessor. getThrowable()
@Nullable java.lang.Throwable
UnicastProcessor. getThrowable()
T
AsyncProcessor. getValue()
Returns a single value this processor currently has or null if no such value exists.T
BehaviorProcessor. getValue()
Returns a single value the BehaviorProcessor currently has or null if no such value exists.T
ReplayProcessor.ReplayBuffer. getValue()
T
ReplayProcessor.SizeAndTimeBoundReplayBuffer. getValue()
T
ReplayProcessor.UnboundedReplayBuffer. getValue()
T
UnicastProcessor.UnicastQueueSubscription. poll()
-
Uses of Nullable in io.reactivex.rxjava3.subjects
Methods in io.reactivex.rxjava3.subjects with annotations of type Nullable Modifier and Type Method Description @Nullable java.lang.Throwable
BehaviorSubject. getThrowable()
@Nullable java.lang.Throwable
CompletableSubject. getThrowable()
Returns the terminal error if this CompletableSubject has been terminated with an error, null otherwise.@Nullable java.lang.Throwable
MaybeSubject. getThrowable()
Returns the terminal error if this MaybeSubject has been terminated with an error, null otherwise.@Nullable java.lang.Throwable
PublishSubject. getThrowable()
@Nullable java.lang.Throwable
ReplaySubject. getThrowable()
@Nullable java.lang.Throwable
SerializedSubject. getThrowable()
@Nullable java.lang.Throwable
SingleSubject. getThrowable()
Returns the terminal error if this SingleSubject has been terminated with an error, null otherwise.abstract @Nullable java.lang.Throwable
Subject. getThrowable()
Returns the error that caused the Subject to terminate or null if the Subject hasn't terminated yet.@Nullable java.lang.Throwable
UnicastSubject. getThrowable()
T
AsyncSubject. getValue()
Returns a single value the Subject currently has or null if no such value exists.T
BehaviorSubject. 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
ReplaySubject. getValue()
Returns a single value the Subject currently has or null if no such value exists.T
ReplaySubject.ReplayBuffer. getValue()
T
ReplaySubject.SizeAndTimeBoundReplayBuffer. getValue()
T
ReplaySubject.SizeBoundReplayBuffer. getValue()
T
ReplaySubject.UnboundedReplayBuffer. getValue()
T
SingleSubject. getValue()
Returns the success value if this SingleSubject was terminated with a success value.T
UnicastSubject.UnicastQueueDisposable. poll()
-