Uses of Interface
io.reactivex.rxjava3.functions.Supplier

Packages that use Supplier

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.internal.functions
io.reactivex.rxjava3.internal.operators.completable
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.operators	Classes and interfaces for writing advanced operators within and outside RxJava.
io.reactivex.rxjava3.parallel	Contains the base type ParallelFlowable, a sub-DSL for working with Flowable sequences in parallel.
io.reactivex.rxjava3.plugins	Contains the central plugin handler RxJavaPlugins class to hook into the lifecycle of the base reactive types and schedulers.

Uses of Supplier in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core with parameters of type Supplier

Modifier and Type	Method	Description
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Flowable<U>	Flowable.buffer(int count, int skip, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns a Flowable that emits buffers of items it collects from the current Flowable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Flowable<U>	Flowable.buffer(int count, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns a Flowable that emits buffers of items it collects from the current Flowable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Flowable<U>	Flowable.buffer(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns a Flowable that emits buffers of items it collects from the current Flowable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Flowable<U>	Flowable.buffer(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int count, @NonNull Supplier<@NonNull U> bufferSupplier, boolean restartTimerOnMaxSize)	Returns a Flowable that emits buffers of items it collects from the current Flowable.
final <@NonNull TOpening, @NonNull TClosing, @NonNull U extends Collection<? super @NonNull T>> @NonNull Flowable<U>	Flowable.buffer(@NonNull org.reactivestreams.Publisher<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull TClosing>> closingIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns a Flowable that emits buffers of items it collects from the current Flowable.
final <@NonNull B, @NonNull U extends Collection<? super @NonNull T>> @NonNull Flowable<U>	Flowable.buffer(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns a Flowable that emits non-overlapping buffered items from the current Flowable each time the specified boundary Publisher emits an item.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Observable<U>	Observable.buffer(int count, int skip, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns an Observable that emits buffers of items it collects from the current Observable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Observable<U>	Observable.buffer(int count, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns an Observable that emits buffers of items it collects from the current Observable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Observable<U>	Observable.buffer(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns an Observable that emits buffers of items it collects from the current Observable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Observable<U>	Observable.buffer(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int count, @NonNull Supplier<@NonNull U> bufferSupplier, boolean restartTimerOnMaxSize)	Returns an Observable that emits buffers of items it collects from the current Observable.
final <@NonNull TOpening, @NonNull TClosing, @NonNull U extends Collection<? super @NonNull T>> @NonNull Observable<U>	Observable.buffer(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, ? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns an Observable that emits buffers of items it collects from the current Observable.
final <@NonNull B, @NonNull U extends Collection<? super @NonNull T>> @NonNull Observable<U>	Observable.buffer(@NonNull ObservableSource<@NonNull B> boundaryIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)	Returns an Observable that emits non-overlapping buffered items from the current Observable each time the specified boundary ObservableSource emits an item.
final <@NonNull U> @NonNull Single<U>	Flowable.collect(@NonNull Supplier<? extends @NonNull U> initialItemSupplier, @NonNull BiConsumer<? super @NonNull U, ? super @NonNull T> collector)	Collects items emitted by the finite source Publisher into a single mutable data structure and returns a Single that emits this structure.
final <@NonNull U> @NonNull Single<U>	Observable.collect(@NonNull Supplier<? extends @NonNull U> initialItemSupplier, @NonNull BiConsumer<? super @NonNull U, ? super @NonNull T> collector)	Collects items emitted by the finite source Observable into a single mutable data structure and returns a Single that emits this structure.
static @NonNull Completable	Completable.defer(@NonNull Supplier<? extends @NonNull CompletableSource> supplier)	Defers the subscription to a Completable instance returned by a supplier.
static <@NonNull T> @NonNull Flowable<T>	Flowable.defer(@NonNull Supplier<? extends @NonNull org.reactivestreams.Publisher<? extends @NonNull T>> supplier)	Returns a Flowable that calls a Publisher factory to create a Publisher for each new Subscriber that subscribes.
static <@NonNull T> @NonNull Maybe<T>	Maybe.defer(@NonNull Supplier<? extends @NonNull MaybeSource<? extends @NonNull T>> supplier)	Calls a Supplier for each individual MaybeObserver to return the actual MaybeSource source to be subscribed to.
static <@NonNull T> @NonNull Observable<T>	Observable.defer(@NonNull Supplier<? extends @NonNull ObservableSource<? extends @NonNull T>> supplier)	Returns an Observable that calls an ObservableSource factory to create an ObservableSource for each new Observer that subscribes.
static <@NonNull T> @NonNull Single<T>	Single.defer(@NonNull Supplier<? extends @NonNull SingleSource<? extends @NonNull T>> supplier)	Calls a Supplier for each individual SingleObserver to return the actual SingleSource to be subscribed to.
final <@NonNull K> @NonNull Flowable<T>	Flowable.distinct(@NonNull Function<? super @NonNull T, @NonNull K> keySelector, @NonNull Supplier<? extends Collection<? super @NonNull K>> collectionSupplier)	Returns a Flowable that emits all items emitted by the current Flowable that are distinct according to a key selector function and based on Object.equals(Object) comparison of the objects returned by the key selector function.
final <@NonNull K> @NonNull Observable<T>	Observable.distinct(@NonNull Function<? super @NonNull T, @NonNull K> keySelector, @NonNull Supplier<? extends Collection<? super @NonNull K>> collectionSupplier)	Returns an Observable that emits all items emitted by the current Observable that are distinct according to a key selector function and based on Object.equals(Object) comparison of the objects returned by the key selector function.
static @NonNull Completable	Completable.error(@NonNull Supplier<? extends @NonNull Throwable> supplier)	Creates a Completable which calls the given error supplier for each subscriber and emits its returned Throwable.
static <@NonNull T> @NonNull Flowable<T>	Flowable.error(@NonNull Supplier<? extends @NonNull Throwable> supplier)	Returns a Flowable that invokes a Subscriber's onError method when the Subscriber subscribes to it.
static <@NonNull T> @NonNull Maybe<T>	Maybe.error(@NonNull Supplier<? extends @NonNull Throwable> supplier)	Returns a Maybe that invokes a MaybeObserver's onError method when the MaybeObserver subscribes to it.
static <@NonNull T> @NonNull Observable<T>	Observable.error(@NonNull Supplier<? extends @NonNull Throwable> supplier)	Returns an Observable that invokes an Observer's onError method when the Observer subscribes to it.
static <@NonNull T> @NonNull Single<T>	Single.error(@NonNull Supplier<? extends @NonNull Throwable> supplier)	Signals a Throwable returned by the callback function for each individual SingleObserver.
final <@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper, @NonNull Function<? super Throwable, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier)	Returns a Flowable that applies a function to each item emitted or notification raised by the current Flowable and then flattens the Publishers returned from these functions and emits the resulting items.
final <@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper, @NonNull Function<Throwable, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency)	Returns a Flowable that applies a function to each item emitted or notification raised by the current Flowable and then flattens the Publishers returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to these Publishers.
final <@NonNull R> @NonNull Maybe<R>	Maybe.flatMap(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> onSuccessMapper, @NonNull Function<? super Throwable, ? extends MaybeSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends MaybeSource<? extends @NonNull R>> onCompleteSupplier)	Maps the onSuccess, onError or onComplete signals of the current Maybe into a MaybeSource and emits that MaybeSource's signals.
final <@NonNull R> @NonNull Observable<R>	Observable.flatMap(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<? super Throwable, ? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier)	Returns an Observable that applies a function to each item emitted or notification raised by the current Observable and then flattens the ObservableSources returned from these functions and emits the resulting items.
final <@NonNull R> @NonNull Observable<R>	Observable.flatMap(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<Throwable, ? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency)	Returns an Observable that applies a function to each item emitted or notification raised by the current Observable and then flattens the ObservableSources returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to these ObservableSources.
static @NonNull Completable	Completable.fromSupplier(@NonNull Supplier<?> supplier)	Returns a Completable which when subscribed, executes the Supplier function, ignores its normal result and emits onError or onComplete only.
static <@NonNull T> @NonNull Flowable<T>	Flowable.fromSupplier(@NonNull Supplier<? extends @NonNull T> supplier)	Returns a Flowable that, when a Subscriber subscribes to it, invokes a supplier function you specify and then emits the value returned from that function.
static <T> @NonNull Maybe<@NonNull T>	Maybe.fromSupplier(@NonNull Supplier<? extends @Nullable T> supplier)	Returns a Maybe that invokes the given Supplier for each individual MaybeObserver that subscribes and emits the resulting non-null item via onSuccess while considering a null result from the Supplier as indication for valueless completion via onComplete.
static <@NonNull T> @NonNull Observable<T>	Observable.fromSupplier(@NonNull Supplier<? extends @NonNull T> supplier)	Returns an Observable that, when an observer subscribes to it, invokes a supplier function you specify and then emits the value returned from that function.
static <@NonNull T> @NonNull Single<T>	Single.fromSupplier(@NonNull Supplier<? extends @NonNull T> supplier)	Returns a Single that invokes passed supplier and emits its result for each individual SingleObserver that subscribes.
static <@NonNull T, @NonNull S> @NonNull Flowable<T>	Flowable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S, Emitter<@NonNull T>> generator)	Returns a cold, synchronous, stateful and backpressure-aware generator of values.
static <@NonNull T, @NonNull S> @NonNull Flowable<T>	Flowable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S, Emitter<@NonNull T>> generator, @NonNull Consumer<? super @NonNull S> disposeState)	Returns a cold, synchronous, stateful and backpressure-aware generator of values.
static <@NonNull T, @NonNull S> @NonNull Flowable<T>	Flowable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, @NonNull Emitter<@NonNull T>, @NonNull S> generator)	Returns a cold, synchronous, stateful and backpressure-aware generator of values.
static <@NonNull T, @NonNull S> @NonNull Flowable<T>	Flowable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, @NonNull Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState)	Returns a cold, synchronous, stateful and backpressure-aware generator of values.
static <@NonNull T, @NonNull S> @NonNull Observable<T>	Observable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S, Emitter<@NonNull T>> generator)	Returns a cold, synchronous and stateful generator of values.
static <@NonNull T, @NonNull S> @NonNull Observable<T>	Observable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S, Emitter<@NonNull T>> generator, @NonNull Consumer<? super @NonNull S> disposeState)	Returns a cold, synchronous and stateful generator of values.
static <@NonNull T, @NonNull S> @NonNull Observable<T>	Observable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator)	Returns a cold, synchronous and stateful generator of values.
static <@NonNull T, @NonNull S> @NonNull Observable<T>	Observable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState)	Returns a cold, synchronous and stateful generator of values.
final <@NonNull R> @NonNull Flowable<R>	Flowable.onBackpressureReduce(@NonNull Supplier<@NonNull R> supplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer)	Reduces upstream values into an aggregate value, provided by a supplier and combined via a reducer function, while the downstream is not ready to receive items, then emits this aggregate value when the downstream becomes ready.
final <@NonNull R> @NonNull Single<R>	Flowable.reduceWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer)	Returns a Single that applies a specified accumulator function to the first item emitted by the current Flowable and a seed value derived from calling a specified seedSupplier, then feeds the result of that function along with the second item emitted by the current Flowable into the same function, and so on until all items have been emitted by the current and finite Flowable, emitting the final result from the final call to your function as its sole item.
final <@NonNull R> @NonNull Single<R>	Observable.reduceWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer)	Returns a Single that applies a specified accumulator function to the first item emitted by the current Observable and a seed value derived from calling a specified seedSupplier, then feeds the result of that function along with the second item emitted by the current Observable into the same function, and so on until all items have been emitted by the current and finite Observable, emitting the final result from the final call to your function as its sole item.
final <@NonNull R> @NonNull Flowable<R>	Flowable.scanWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator)	Returns a Flowable that emits the provided initial (seed) value, then emits one value for each value emitted by the current Flowable.
final <@NonNull R> @NonNull Observable<R>	Observable.scanWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator)	Returns an Observable that emits the provided initial (seed) value, then emits one value for each value emitted by the current Observable.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Single<U>	Flowable.toList(@NonNull Supplier<@NonNull U> collectionSupplier)	Returns a Single that emits a single item, a list composed of all the items emitted by the finite source Publisher.
final <@NonNull U extends Collection<? super @NonNull T>> @NonNull Single<U>	Observable.toList(@NonNull Supplier<@NonNull U> collectionSupplier)	Returns a Single that emits a single item, a Collection (subclass) composed of all the items emitted by the finite upstream Observable.
final <@NonNull K, @NonNull V> @NonNull Single<Map<K,V>>	Flowable.toMap(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, @NonNull V>> mapSupplier)	Returns a Single that emits a single Map, returned by a specified mapFactory function, that contains keys and values extracted from the items emitted by the finite source Publisher.
final <@NonNull K, @NonNull V> @NonNull Single<Map<K,V>>	Observable.toMap(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, @NonNull V>> mapSupplier)	Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that contains keys and values extracted from the items, via selector functions, emitted by the current and finite Observable.
final <@NonNull K, @NonNull V> @NonNull Single<Map<K, Collection<V>>>	Flowable.toMultimap(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, Collection<@NonNull V>>> mapSupplier, @NonNull Function<? super @NonNull K, ? extends Collection<? super @NonNull V>> collectionFactory)	Returns a Single that emits a single Map, returned by a specified mapFactory function, that contains a custom collection of values, extracted by a specified valueSelector function from items emitted by the finite source Publisher, and keyed by the keySelector function.
final <@NonNull K, @NonNull V> @NonNull Single<Map<K, Collection<V>>>	Flowable.toMultimap(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<Map<@NonNull K, Collection<@NonNull V>>> mapSupplier)	Returns a Single that emits a single Map, returned by a specified mapFactory function, that contains an ArrayList of values, extracted by a specified valueSelector function from items emitted by the finite source Publisher and keyed by the keySelector function.
final <@NonNull K, @NonNull V> @NonNull Single<@NonNull Map<K, Collection<V>>>	Observable.toMultimap(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, Collection<@NonNull V>>> mapSupplier, @NonNull Function<? super @NonNull K, ? extends Collection<? super @NonNull V>> collectionFactory)	Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that contains a custom Collection of values, extracted by a specified valueSelector function from items emitted by the current and finite Observable, and keyed by the keySelector function.
final <@NonNull K, @NonNull V> @NonNull Single<@NonNull Map<K, Collection<V>>>	Observable.toMultimap(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<Map<@NonNull K, Collection<@NonNull V>>> mapSupplier)	Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that contains an ArrayList of values, extracted by a specified valueSelector function from items emitted by the current and finite Observable and keyed by the keySelector function.
final <@NonNull T> @NonNull Single<T>	Completable.toSingle(@NonNull Supplier<? extends @NonNull T> completionValueSupplier)	Converts this Completable into a Single which when this Completable completes normally, calls the given Supplier and emits its returned value through onSuccess.
static <@NonNull R> @NonNull Completable	Completable.using(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup)	Returns a Completable instance which manages a resource along with a custom CompletableSource instance while the subscription is active.
static <@NonNull R> @NonNull Completable	Completable.using(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup, boolean eager)	Returns a Completable instance which manages a resource along with a custom CompletableSource instance while the subscription is active and performs eager or lazy resource disposition.
static <@NonNull T, @NonNull D> @NonNull Flowable<T>	Flowable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup)	Constructs a Flowable that creates a dependent resource object, a Publisher with that resource and calls the provided resourceDisposer function if this inner source terminates or the downstream cancels the flow.
static <@NonNull T, @NonNull D> @NonNull Flowable<T>	Flowable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager)	Constructs a Flowable that creates a dependent resource object, a Publisher with that resource and calls the provided resourceDisposer function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached if eager == true, after otherwise.
static <@NonNull T, @NonNull D> @NonNull Maybe<T>	Maybe.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends MaybeSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup)	Constructs a Maybe that creates a dependent resource object which is disposed of when the generated MaybeSource terminates or the downstream calls dispose().
static <@NonNull T, @NonNull D> @NonNull Maybe<T>	Maybe.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends MaybeSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager)	Constructs a Maybe that creates a dependent resource object which is disposed first ({code eager == true}) when the generated MaybeSource terminates or the downstream disposes; or after ({code eager == false}).
static <@NonNull T, @NonNull D> @NonNull Observable<T>	Observable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup)	Constructs an Observable that creates a dependent resource object, an ObservableSource with that resource and calls the provided resourceDisposer function if this inner source terminates or the downstream disposes the flow.
static <@NonNull T, @NonNull D> @NonNull Observable<T>	Observable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager)	Constructs an Observable that creates a dependent resource object, an ObservableSource with that resource and calls the provided disposer function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached if eager == true, after otherwise.
static <@NonNull T, @NonNull U> @NonNull Single<T>	Single.using(@NonNull Supplier<@NonNull U> resourceSupplier, @NonNull Function<? super @NonNull U, ? extends SingleSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull U> resourceCleanup)	Allows using and disposing a resource while running a SingleSource instance generated from that resource (similar to a try-with-resources).
static <@NonNull T, @NonNull U> @NonNull Single<T>	Single.using(@NonNull Supplier<@NonNull U> resourceSupplier, @NonNull Function<? super @NonNull U, ? extends SingleSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull U> resourceCleanup, boolean eager)	Allows using and disposing a resource while running a SingleSource instance generated from that resource (similar to a try-with-resources).

Uses of Supplier in io.reactivex.rxjava3.internal.functions

Methods in io.reactivex.rxjava3.internal.functions that return Supplier

Modifier and Type	Method	Description
static <T> Supplier<List<T>>	Functions.createArrayList(int capacity)
static <T> Supplier<Set<T>>	Functions.createHashSet()
static <T> @NonNull Supplier<T>	Functions.justSupplier(T value)	Returns a Supplier that returns the given value.
static <T> @NonNull Supplier<T>	Functions.nullSupplier()

Uses of Supplier in io.reactivex.rxjava3.internal.operators.completable

Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type Supplier

Modifier	Constructor	Description
	CompletableDefer(Supplier<? extends CompletableSource> completableSupplier)
	CompletableErrorSupplier(Supplier<? extends Throwable> errorSupplier)
	CompletableFromSupplier(Supplier<?> supplier)
	CompletableToSingle(CompletableSource source, Supplier<? extends T> completionValueSupplier, T completionValue)
	CompletableUsing(Supplier<R> resourceSupplier, Function<? super R, ? extends CompletableSource> completableFunction, Consumer<? super R> disposer, boolean eager)

Uses of Supplier in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement Supplier

Modifier and Type	Class	Description
final class	FlowableEmpty	A source Flowable that signals an onSubscribe() + onComplete() only.
final class	FlowableFromAction<T>	Executes an Action and signals its exception or completes normally.
final class	FlowableFromCallable<T>
final class	FlowableFromRunnable<T>	Executes an Runnable and signals its exception or completes normally.
final class	FlowableFromSupplier<T>	Call a Supplier for each incoming Subscriber and signal the returned value or the thrown exception.
final class	FlowableJust<T>	Represents a constant scalar value.

Methods in io.reactivex.rxjava3.internal.operators.flowable that return Supplier

Modifier and Type	Method	Description
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent)
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent, int bufferSize, boolean eagerTruncate)
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)

Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Supplier

Modifier and Type	Method	Description
static <U,R> Flowable<R>	FlowableReplay.multicastSelector(Supplier<? extends ConnectableFlowable<U>> connectableFactory, Function<? super Flowable<U>, ? extends org.reactivestreams.Publisher<R>> selector)	Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Supplier

Modifier	Constructor	Description
	FlowableBuffer(Flowable<T> source, int size, int skip, Supplier<C> bufferSupplier)
	FlowableBufferBoundary(Flowable<T> source, org.reactivestreams.Publisher<? extends Open> bufferOpen, Function<? super Open, ? extends org.reactivestreams.Publisher<? extends Close>> bufferClose, Supplier<U> bufferSupplier)
	FlowableBufferExactBoundary(Flowable<T> source, org.reactivestreams.Publisher<B> boundary, Supplier<U> bufferSupplier)
	FlowableBufferTimed(Flowable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Supplier<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize)
	FlowableCollect(Flowable<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U, ? super T> collector)
	FlowableCollectSingle(Flowable<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U, ? super T> collector)
	FlowableDefer(Supplier<? extends org.reactivestreams.Publisher<? extends T>> supplier)
	FlowableDistinct(Flowable<T> source, Function<? super T, K> keySelector, Supplier<? extends Collection<? super K>> collectionSupplier)
	FlowableError(Supplier<? extends Throwable> errorSupplier)
	FlowableFromSupplier(Supplier<? extends T> supplier)
	FlowableGenerate(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState)
	FlowableMapNotification(Flowable<T> source, Function<? super T, ? extends R> onNextMapper, Function<? super Throwable, ? extends R> onErrorMapper, Supplier<? extends R> onCompleteSupplier)
	FlowableOnBackpressureReduceWith(@NonNull Flowable<T> source, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer)
	FlowableReduceWithSingle(org.reactivestreams.Publisher<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> reducer)
	FlowableScanSeed(Flowable<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> accumulator)
	FlowableToList(Flowable<T> source, Supplier<U> collectionSupplier)
	FlowableToListSingle(Flowable<T> source, Supplier<U> collectionSupplier)
	FlowableUsing(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager)

Uses of Supplier in io.reactivex.rxjava3.internal.operators.maybe

Classes in io.reactivex.rxjava3.internal.operators.maybe that implement Supplier

Modifier and Type	Class	Description
final class	MaybeEmpty	Signals an onComplete.
final class	MaybeFromAction<T>	Executes an Action and signals its exception or completes normally.
final class	MaybeFromCallable<T>	Executes a callable and signals its value as success or signals an exception.
final class	MaybeFromRunnable<T>	Executes an Runnable and signals its exception or completes normally.
final class	MaybeFromSupplier<T>	Executes a supplier and signals its value as success or signals an exception.
final class	MaybeJust<T>	Signals a constant value.

Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type Supplier

Modifier	Constructor	Description
	MaybeDefer(Supplier<? extends MaybeSource<? extends T>> maybeSupplier)
	MaybeErrorCallable(Supplier<? extends Throwable> errorSupplier)
	MaybeFlatMapNotification(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier)
	MaybeFromSupplier(Supplier<? extends T> supplier)
	MaybeUsing(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends MaybeSource<? extends T>> sourceSupplier, Consumer<? super D> resourceDisposer, boolean eager)

Uses of Supplier in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement Supplier

Modifier and Type	Class	Description
final class	ObservableEmpty
final class	ObservableFromAction<T>	Executes an Action and signals its exception or completes normally.
final class	ObservableFromCallable<T>	Calls a Callable and emits its resulting single value or signals its exception.
final class	ObservableFromRunnable<T>	Executes an Runnable and signals its exception or completes normally.
final class	ObservableFromSupplier<T>	Calls a Supplier and emits its resulting single value or signals its exception.
final class	ObservableJust<T>	Represents a constant scalar value.

Methods in io.reactivex.rxjava3.internal.operators.observable that return Supplier

Modifier and Type	Method	Description
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent)
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent, int bufferSize, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)

Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type Supplier

Modifier and Type	Method	Description
static <U,R> Observable<R>	ObservableReplay.multicastSelector(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>, ? extends ObservableSource<R>> selector)	Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Supplier

Modifier	Constructor	Description
	ObservableBuffer(ObservableSource<T> source, int count, int skip, Supplier<U> bufferSupplier)
	ObservableBufferBoundary(ObservableSource<T> source, ObservableSource<? extends Open> bufferOpen, Function<? super Open, ? extends ObservableSource<? extends Close>> bufferClose, Supplier<U> bufferSupplier)
	ObservableBufferExactBoundary(ObservableSource<T> source, ObservableSource<B> boundary, Supplier<U> bufferSupplier)
	ObservableBufferTimed(ObservableSource<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Supplier<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize)
	ObservableCollect(ObservableSource<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U, ? super T> collector)
	ObservableCollectSingle(ObservableSource<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U, ? super T> collector)
	ObservableDefer(Supplier<? extends ObservableSource<? extends T>> supplier)
	ObservableDistinct(ObservableSource<T> source, Function<? super T, K> keySelector, Supplier<? extends Collection<? super K>> collectionSupplier)
	ObservableError(Supplier<? extends Throwable> errorSupplier)
	ObservableFromSupplier(Supplier<? extends T> supplier)
	ObservableGenerate(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState)
	ObservableMapNotification(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper, Function<? super Throwable, ? extends ObservableSource<? extends R>> onErrorMapper, Supplier<? extends ObservableSource<? extends R>> onCompleteSupplier)
	ObservableReduceWithSingle(ObservableSource<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> reducer)
	ObservableScanSeed(ObservableSource<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> accumulator)
	ObservableToList(ObservableSource<T> source, Supplier<U> collectionSupplier)
	ObservableToListSingle(ObservableSource<T> source, Supplier<U> collectionSupplier)
	ObservableUsing(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends ObservableSource<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager)

Uses of Supplier in io.reactivex.rxjava3.internal.operators.parallel

Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Supplier

Modifier	Constructor	Description
	ParallelCollect(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C, ? super T> collector)
	ParallelReduce(ParallelFlowable<? extends T> source, Supplier<R> initialSupplier, BiFunction<R, ? super T, R> reducer)

Uses of Supplier in io.reactivex.rxjava3.internal.operators.single

Methods in io.reactivex.rxjava3.internal.operators.single that return Supplier

Modifier and Type	Method	Description
static Supplier<NoSuchElementException>	SingleInternalHelper.emptyThrower()

Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type Supplier

Modifier	Constructor	Description
	SingleDefer(Supplier<? extends SingleSource<? extends T>> singleSupplier)
	SingleError(Supplier<? extends Throwable> errorSupplier)
	SingleFromSupplier(Supplier<? extends T> supplier)
	SingleUsing(Supplier<U> resourceSupplier, Function<? super U, ? extends SingleSource<? extends T>> singleFunction, Consumer<? super U> disposer, boolean eager)

Uses of Supplier in io.reactivex.rxjava3.internal.util

Classes in io.reactivex.rxjava3.internal.util that implement Supplier

Modifier and Type	Class	Description
enum	ArrayListSupplier
enum	HashMapSupplier

Methods in io.reactivex.rxjava3.internal.util that return Supplier

Modifier and Type	Method	Description
static <T> Supplier<List<T>>	ArrayListSupplier.asSupplier()
static <K,V> Supplier<Map<K,V>>	HashMapSupplier.asSupplier()

Uses of Supplier in io.reactivex.rxjava3.operators

Subinterfaces of Supplier in io.reactivex.rxjava3.operators

Modifier and Type	Interface	Description
interface	ScalarSupplier<T>	A marker interface indicating that a scalar, constant value is held by the implementing reactive type which can be safely extracted during assembly time can be used for optimization.

Uses of Supplier in io.reactivex.rxjava3.parallel

Methods in io.reactivex.rxjava3.parallel with parameters of type Supplier

Modifier and Type	Method	Description
final <@NonNull C> @NonNull ParallelFlowable<C>	ParallelFlowable.collect(@NonNull Supplier<? extends @NonNull C> collectionSupplier, @NonNull BiConsumer<? super @NonNull C, ? super @NonNull T> collector)	Collect the elements in each rail into a collection supplied via a collectionSupplier and collected into with a collector action, emitting the collection at the end.
final <@NonNull R> @NonNull ParallelFlowable<R>	ParallelFlowable.reduce(@NonNull Supplier<@NonNull R> initialSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer)	Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from an initialSupplier value.

Uses of Supplier in io.reactivex.rxjava3.plugins

Methods in io.reactivex.rxjava3.plugins that return types with arguments of type Supplier

Modifier and Type	Method	Description
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.

Methods in io.reactivex.rxjava3.plugins with parameters of type Supplier

Modifier and Type	Method	Description
static @NonNull Scheduler	RxJavaPlugins.initComputationScheduler(@NonNull Supplier<Scheduler> defaultScheduler)	Calls the associated hook function.
static @NonNull Scheduler	RxJavaPlugins.initIoScheduler(@NonNull Supplier<Scheduler> defaultScheduler)	Calls the associated hook function.
static @NonNull Scheduler	RxJavaPlugins.initNewThreadScheduler(@NonNull Supplier<Scheduler> defaultScheduler)	Calls the associated hook function.
static @NonNull Scheduler	RxJavaPlugins.initSingleScheduler(@NonNull Supplier<Scheduler> defaultScheduler)	Calls the associated hook function.

Method parameters in io.reactivex.rxjava3.plugins with type arguments of type Supplier

Modifier and Type	Method	Description
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.