Uses of Annotation Interface
io.reactivex.rxjava3.annotations.Nullable

Packages that use Nullable

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.disposables	Default implementations for Disposable-based resource management (Disposable container types) and utility classes to construct Disposables from callbacks and other types.
io.reactivex.rxjava3.flowables	Classes supporting the Flowable base reactive class: ConnectableFlowable and GroupedFlowable.
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 and GroupedObservable.
io.reactivex.rxjava3.observers	Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestObserver that allows unit testing Observable-, Single-, Maybe- and Completable-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 handler RxJavaPlugins 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 the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.
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 Thread	Scheduler.DisposeTask.runner

Methods in io.reactivex.rxjava3.core with annotations of type Nullable

Modifier and Type	Method	Description
final T	Maybe.blockingGet()	Waits in a blocking fashion until the current Maybe signals a success value (which is returned), null if completed or an exception (which is propagated).
@Nullable 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.

Method parameters in io.reactivex.rxjava3.core with annotations of type Nullable

Modifier and Type	Method	Description
final @NonNull CompletionStage<T>	Flowable.firstStage(@NonNull T defaultItem)	Signals the first upstream item (or the default item if the upstream is empty) via a CompletionStage.
final @NonNull CompletionStage<T>	Observable.firstStage(@NonNull T defaultItem)	Signals the first upstream item (or the default item if the upstream is empty) via a CompletionStage.
final @NonNull CompletionStage<T>	Flowable.lastStage(@NonNull T defaultItem)	Signals the last upstream item (or the default item if the upstream is empty) via a CompletionStage.
final @NonNull CompletionStage<T>	Observable.lastStage(@NonNull T defaultItem)	Signals the last upstream item (or the default item if the upstream is empty) via a CompletionStage.
final @NonNull Flowable<T>	Flowable.onBackpressureBuffer(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy)	Buffers an optionally unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.
final @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 current Flowable 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 previous Disposable or Cancellable will be disposed/cancelled.
void	FlowableEmitter.setCancellable(@Nullable Cancellable c)	Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	MaybeEmitter.setCancellable(@Nullable Cancellable c)	Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	ObservableEmitter.setCancellable(@Nullable Cancellable c)	Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	SingleEmitter.setCancellable(@Nullable Cancellable c)	Sets a Cancellable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	CompletableEmitter.setDisposable(@Nullable Disposable d)	Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	FlowableEmitter.setDisposable(@Nullable Disposable d)	Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	MaybeEmitter.setDisposable(@Nullable Disposable d)	Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	ObservableEmitter.setDisposable(@Nullable Disposable d)	Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
void	SingleEmitter.setDisposable(@Nullable Disposable d)	Sets a Disposable on this emitter; any previous Disposable or Cancellable will be disposed/cancelled.
final @NonNull CompletionStage<T>	Flowable.singleStage(@NonNull T defaultItem)	Signals the only expected upstream item (or the default item if the upstream is empty) or signals IllegalArgumentException if the upstream has more than one item via a CompletionStage.
final @NonNull CompletionStage<T>	Observable.singleStage(@NonNull T defaultItem)	Signals the only expected upstream item (or the default item if the upstream is empty) or signals IllegalArgumentException if the upstream has more than one item via a CompletionStage.
private @NonNull Observable<T>	Observable.timeout0(long timeout, @NonNull 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)
final @NonNull CompletionStage<T>	Maybe.toCompletionStage(@NonNull T defaultItem)	Signals the upstream success item (or the default item if the upstream is empty) via a CompletionStage.

Constructor parameters in io.reactivex.rxjava3.core with annotations of type Nullable

Modifier	Constructor	Description
private	Notification(@Nullable 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 the OpenHashSet by suppressing non-fatal Throwables 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

Modifier	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 this GroupedFlowable.

Constructor parameters in io.reactivex.rxjava3.flowables with annotations of type Nullable

Modifier	Constructor	Description
protected	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 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
final 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) final @Nullable org.reactivestreams.Publisher<? extends T>[]	FlowableCombineLatest.array
(package private) final @Nullable Iterable<? extends org.reactivestreams.Publisher<? extends T>>	FlowableCombineLatest.iterable
(package private) final @Nullable org.reactivestreams.Publisher<?>[]	FlowableWithLatestFromMany.otherArray
(package private) final @Nullable 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()
final T	FlowableFromArray.BaseArraySubscription.poll()
final 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()
final @Nullable Integer	FlowableRange.BaseRangeSubscription.poll()
final @Nullable 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) final @Nullable ObservableSource<?>[]	ObservableWithLatestFromMany.otherArray
(package private) final @Nullable 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 Integer	ObservableRange.RangeDisposable.poll()
@Nullable 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(Runnable run, long delayTime, @NonNull 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
final T	DeferredScalarSubscription.poll()
@Nullable 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 this GroupedObservable.

Constructor parameters in io.reactivex.rxjava3.observables with annotations of type Nullable

Modifier	Constructor	Description
protected	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 String	BaseTestConsumer.valueAndClass(@Nullable Object o)	Appends the class name to a non-null value or returns "null".
final U	BaseTestConsumer.withTag(@Nullable 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 or null if this queue is empty
T	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 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, @NonNull ? super CompletableObserver, @NonNull ? 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, @NonNull ? super org.reactivestreams.Subscriber, @NonNull ? 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, @NonNull ? super MaybeObserver, @NonNull ? 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, @NonNull ? super Observer, @NonNull ? extends Observer>	RxJavaPlugins.onObservableSubscribe
(package private) static @Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable>	RxJavaPlugins.onParallelAssembly
(package private) static @Nullable BiFunction<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]>	RxJavaPlugins.onParallelSubscribe
(package private) static @Nullable Function<? super Runnable, ? extends 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, @NonNull ? super SingleObserver, @NonNull ? 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 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, @NonNull ? super CompletableObserver, @NonNull ? 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, @NonNull ? super org.reactivestreams.Subscriber, @NonNull ? 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, @NonNull ? super MaybeObserver, @NonNull ? 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, @NonNull ? super Observer, @NonNull ? 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, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? 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, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver>	RxJavaPlugins.getOnSingleSubscribe()	Returns the current hook function.
static @Nullable Function<? super Runnable, ? extends 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 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, @NonNull ? super CompletableObserver, @NonNull ? 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, @NonNull ? super org.reactivestreams.Subscriber, @NonNull ? 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, @NonNull ? 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, @NonNull ? super Observer, @NonNull ? 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, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? 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, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> onSingleSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setScheduleHandler(@Nullable Function<? super Runnable, ? extends 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 Throwable	AsyncProcessor.getThrowable()
@Nullable Throwable	BehaviorProcessor.getThrowable()
abstract @Nullable Throwable	FlowableProcessor.getThrowable()	Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor hasn't terminated yet.
@Nullable Throwable	PublishProcessor.getThrowable()
@Nullable Throwable	ReplayProcessor.getThrowable()
@Nullable Throwable	SerializedProcessor.getThrowable()
@Nullable 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 Throwable	BehaviorSubject.getThrowable()
@Nullable Throwable	CompletableSubject.getThrowable()	Returns the terminal error if this CompletableSubject has been terminated with an error, null otherwise.
@Nullable Throwable	MaybeSubject.getThrowable()	Returns the terminal error if this MaybeSubject has been terminated with an error, null otherwise.
@Nullable Throwable	PublishSubject.getThrowable()
@Nullable Throwable	ReplaySubject.getThrowable()
@Nullable Throwable	SerializedSubject.getThrowable()
@Nullable Throwable	SingleSubject.getThrowable()	Returns the terminal error if this SingleSubject has been terminated with an error, null otherwise.
abstract @Nullable Throwable	Subject.getThrowable()	Returns the error that caused the Subject to terminate or null if the Subject hasn't terminated yet.
@Nullable 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()