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
andCompletable
; 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 typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel.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.schedulers Contains notably the factory class ofSchedulers
providing methods for retrieving the standard scheduler instances, theTestScheduler
for testing flows with scheduling in a controlled manner and the classTimed
that can hold a value and a timestamp associated with it. -
-
Uses of Supplier in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type Supplier Modifier and Type Method Description <@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Flowable<U>Flowable. buffer(int count, int skip, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Flowable<U>Flowable. buffer(int count, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Flowable<U>Flowable. buffer(long timespan, long timeskip, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Flowable<U>Flowable. buffer(long timespan, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler, int count, @NonNull Supplier<@NonNull U> bufferSupplier, boolean restartTimerOnMaxSize)
Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.<@NonNull TOpening,@NonNull TClosing,@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Flowable<U>Flowable. buffer(@NonNull org.reactivestreams.Publisher<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening,? extends org.reactivestreams.Publisher<? extends @NonNull TClosing>> closingIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.<@NonNull B,@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Flowable<U>Flowable. buffer(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns aFlowable
that emits non-overlapping buffered items from the currentFlowable
each time the specified boundaryPublisher
emits an item.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Observable<U>Observable. buffer(int count, int skip, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns anObservable
that emits buffers of items it collects from the currentObservable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Observable<U>Observable. buffer(int count, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns anObservable
that emits buffers of items it collects from the currentObservable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Observable<U>Observable. buffer(long timespan, long timeskip, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns anObservable
that emits buffers of items it collects from the currentObservable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Observable<U>Observable. buffer(long timespan, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler, int count, @NonNull Supplier<@NonNull U> bufferSupplier, boolean restartTimerOnMaxSize)
Returns anObservable
that emits buffers of items it collects from the currentObservable
.<@NonNull TOpening,@NonNull TClosing,@NonNull U extends java.util.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 anObservable
that emits buffers of items it collects from the currentObservable
.<@NonNull B,@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Observable<U>Observable. buffer(@NonNull ObservableSource<@NonNull B> boundaryIndicator, @NonNull Supplier<@NonNull U> bufferSupplier)
Returns anObservable
that emits non-overlapping buffered items from the currentObservable
each time the specified boundaryObservableSource
emits an item.<@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 sourcePublisher
into a single mutable data structure and returns aSingle
that emits this structure.<@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 sourceObservable
into a single mutable data structure and returns aSingle
that emits this structure.static @NonNull Completable
Completable. defer(@NonNull Supplier<? extends @NonNull CompletableSource> supplier)
Defers the subscription to aCompletable
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 aFlowable
that calls aPublisher
factory to create aPublisher
for each newSubscriber
that subscribes.static <@NonNull T>
@NonNull Maybe<T>Maybe. defer(@NonNull Supplier<? extends @NonNull MaybeSource<? extends @NonNull T>> supplier)
Calls aSupplier
for each individualMaybeObserver
to return the actualMaybeSource
source to be subscribed to.static <@NonNull T>
@NonNull Observable<T>Observable. defer(@NonNull Supplier<? extends @NonNull ObservableSource<? extends @NonNull T>> supplier)
Returns anObservable
that calls anObservableSource
factory to create anObservableSource
for each newObserver
that subscribes.static <@NonNull T>
@NonNull Single<T>Single. defer(@NonNull Supplier<? extends @NonNull SingleSource<? extends @NonNull T>> supplier)
Calls aSupplier
for each individualSingleObserver
to return the actualSingleSource
to be subscribed to.<@NonNull K>
@NonNull Flowable<T>Flowable. distinct(@NonNull Function<? super @NonNull T,@NonNull K> keySelector, @NonNull Supplier<? extends java.util.Collection<? super @NonNull K>> collectionSupplier)
Returns aFlowable
that emits all items emitted by the currentFlowable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.<@NonNull K>
@NonNull Observable<T>Observable. distinct(@NonNull Function<? super @NonNull T,@NonNull K> keySelector, @NonNull Supplier<? extends java.util.Collection<? super @NonNull K>> collectionSupplier)
Returns anObservable
that emits all items emitted by the currentObservable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.static @NonNull Completable
Completable. error(@NonNull Supplier<? extends @NonNull java.lang.Throwable> supplier)
Creates aCompletable
which calls the given error supplier for each subscriber and emits its returnedThrowable
.static <@NonNull T>
@NonNull Flowable<T>Flowable. error(@NonNull Supplier<? extends @NonNull java.lang.Throwable> supplier)
Returns aFlowable
that invokes aSubscriber
'sonError
method when theSubscriber
subscribes to it.static <@NonNull T>
@NonNull Maybe<T>Maybe. error(@NonNull Supplier<? extends @NonNull java.lang.Throwable> supplier)
Returns aMaybe
that invokes aMaybeObserver
'sonError
method when theMaybeObserver
subscribes to it.static <@NonNull T>
@NonNull Observable<T>Observable. error(@NonNull Supplier<? extends @NonNull java.lang.Throwable> supplier)
static <@NonNull T>
@NonNull Single<T>Single. error(@NonNull Supplier<? extends @NonNull java.lang.Throwable> supplier)
Signals aThrowable
returned by the callback function for each individualSingleObserver
.<@NonNull R>
@NonNull Flowable<R>Flowable. flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper, @NonNull Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier)
Returns aFlowable
that applies a function to each item emitted or notification raised by the currentFlowable
and then flattens thePublisher
s returned from these functions and emits the resulting items.<@NonNull R>
@NonNull Flowable<R>Flowable. flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper, @NonNull Function<java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency)
Returns aFlowable
that applies a function to each item emitted or notification raised by the currentFlowable
and then flattens thePublisher
s returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.<@NonNull R>
@NonNull Maybe<R>Maybe. flatMap(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> onSuccessMapper, @NonNull Function<? super java.lang.Throwable,? extends MaybeSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends MaybeSource<? extends @NonNull R>> onCompleteSupplier)
Maps theonSuccess
,onError
oronComplete
signals of the currentMaybe
into aMaybeSource
and emits thatMaybeSource
's signals.<@NonNull R>
@NonNull Observable<R>Observable. flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<? super java.lang.Throwable,? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier)
Returns anObservable
that applies a function to each item emitted or notification raised by the currentObservable
and then flattens theObservableSource
s returned from these functions and emits the resulting items.<@NonNull R>
@NonNull Observable<R>Observable. flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<java.lang.Throwable,? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency)
Returns anObservable
that applies a function to each item emitted or notification raised by the currentObservable
and then flattens theObservableSource
s returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.static @NonNull Completable
Completable. fromSupplier(@NonNull Supplier<?> supplier)
Returns aCompletable
which when subscribed, executes theSupplier
function, ignores its normal result and emitsonError
oronComplete
only.static <@NonNull T>
@NonNull Flowable<T>Flowable. fromSupplier(@NonNull Supplier<? extends @NonNull T> supplier)
Returns aFlowable
that, when aSubscriber
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 aMaybe
that invokes the givenSupplier
for each individualMaybeObserver
that subscribes and emits the resulting non-null
item viaonSuccess
while considering anull
result from theSupplier
as indication for valueless completion viaonComplete
.static <@NonNull T>
@NonNull Observable<T>Observable. fromSupplier(@NonNull Supplier<? extends @NonNull T> supplier)
Returns anObservable
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 aSingle
that invokes passed supplier and emits its result for each individualSingleObserver
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.<@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.<@NonNull R>
@NonNull Single<R>Flowable. reduceWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)
Returns aSingle
that applies a specified accumulator function to the first item emitted by the currentFlowable
and a seed value derived from calling a specifiedseedSupplier
, then feeds the result of that function along with the second item emitted by the currentFlowable
into the same function, and so on until all items have been emitted by the current and finiteFlowable
, emitting the final result from the final call to your function as its sole item.<@NonNull R>
@NonNull Single<R>Observable. reduceWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)
Returns aSingle
that applies a specified accumulator function to the first item emitted by the currentObservable
and a seed value derived from calling a specifiedseedSupplier
, then feeds the result of that function along with the second item emitted by the currentObservable
into the same function, and so on until all items have been emitted by the current and finiteObservable
, emitting the final result from the final call to your function as its sole item.<@NonNull R>
@NonNull Flowable<R>Flowable. scanWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator)
Returns aFlowable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentFlowable
.<@NonNull R>
@NonNull Observable<R>Observable. scanWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator)
Returns anObservable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentObservable
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Single<U>Flowable. toList(@NonNull Supplier<@NonNull U> collectionSupplier)
Returns aSingle
that emits a single item, a list composed of all the items emitted by the finite sourcePublisher
.<@NonNull U extends java.util.Collection<? super @NonNull T>>
@NonNull Single<U>Observable. toList(@NonNull Supplier<@NonNull U> collectionSupplier)
Returns aSingle
that emits a single item, aCollection
(subclass) composed of all the items emitted by the finite upstreamObservable
.<@NonNull K,@NonNull V>
@NonNull Single<java.util.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 java.util.Map<@NonNull K,@NonNull V>> mapSupplier)
Returns aSingle
that emits a singleMap
, returned by a specifiedmapFactory
function, that contains keys and values extracted from the items emitted by the finite sourcePublisher
.<@NonNull K,@NonNull V>
@NonNull Single<java.util.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 java.util.Map<@NonNull K,@NonNull V>> mapSupplier)
Returns aSingle
that emits a singleMap
(subclass), returned by a specifiedmapFactory
function, that contains keys and values extracted from the items, via selector functions, emitted by the current and finiteObservable
.<@NonNull K,@NonNull V>
@NonNull Single<java.util.Map<K,java.util.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 java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier, @NonNull Function<? super @NonNull K,? extends java.util.Collection<? super @NonNull V>> collectionFactory)
Returns aSingle
that emits a singleMap
, returned by a specifiedmapFactory
function, that contains a custom collection of values, extracted by a specifiedvalueSelector
function from items emitted by the finite sourcePublisher
, and keyed by thekeySelector
function.<@NonNull K,@NonNull V>
@NonNull Single<java.util.Map<K,java.util.Collection<V>>>Flowable. toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector, @NonNull Supplier<java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier)
Returns aSingle
that emits a singleMap
, returned by a specifiedmapFactory
function, that contains anArrayList
of values, extracted by a specifiedvalueSelector
function from items emitted by the finite sourcePublisher
and keyed by thekeySelector
function.<@NonNull K,@NonNull V>
@NonNull Single<@NonNull java.util.Map<K,java.util.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 java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier, @NonNull Function<? super @NonNull K,? extends java.util.Collection<? super @NonNull V>> collectionFactory)
Returns aSingle
that emits a singleMap
(subclass), returned by a specifiedmapFactory
function, that contains a customCollection
of values, extracted by a specifiedvalueSelector
function from items emitted by the current and finiteObservable
, and keyed by thekeySelector
function.<@NonNull K,@NonNull V>
@NonNull Single<@NonNull java.util.Map<K,java.util.Collection<V>>>Observable. toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector, @NonNull Supplier<java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier)
Returns aSingle
that emits a singleMap
(subclass), returned by a specifiedmapFactory
function, that contains anArrayList
of values, extracted by a specifiedvalueSelector
function from items emitted by the current and finiteObservable
and keyed by thekeySelector
function.<@NonNull T>
@NonNull Single<T>Completable. toSingle(@NonNull Supplier<? extends @NonNull T> completionValueSupplier)
static <@NonNull R>
@NonNull CompletableCompletable. using(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R,? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup)
Returns aCompletable
instance which manages a resource along with a customCompletableSource
instance while the subscription is active.static <@NonNull R>
@NonNull CompletableCompletable. using(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R,? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup, boolean eager)
Returns aCompletable
instance which manages a resource along with a customCompletableSource
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,? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup)
Constructs aFlowable
that creates a dependent resource object, aPublisher
with that resource and calls the providedresourceDisposer
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,? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager)
Constructs aFlowable
that creates a dependent resource object, aPublisher
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == 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 aMaybe
that creates a dependent resource object which is disposed of when the generatedMaybeSource
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 aMaybe
that creates a dependent resource object which is disposed first ({code eager == true}) when the generatedMaybeSource
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 anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the providedresourceDisposer
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 anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the provideddisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == 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 aSingleSource
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 aSingleSource
instance generated from that resource (similar to a try-with-resources). -
Uses of Supplier in io.reactivex.rxjava3.internal.functions
Classes in io.reactivex.rxjava3.internal.functions that implement Supplier Modifier and Type Class Description (package private) static class
Functions.ArrayListCapacityCallable<T>
(package private) static class
Functions.HashSetSupplier
(package private) static class
Functions.JustValue<T,U>
(package private) static class
Functions.NullProvider
Fields in io.reactivex.rxjava3.internal.functions declared as Supplier Modifier and Type Field Description (package private) static Supplier<java.lang.Object>
Functions. NULL_SUPPLIER
Methods in io.reactivex.rxjava3.internal.functions that return Supplier Modifier and Type Method Description static <T> Supplier<java.util.List<T>>
Functions. createArrayList(int capacity)
static <T> Supplier<java.util.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
Fields in io.reactivex.rxjava3.internal.operators.completable declared as Supplier Modifier and Type Field Description (package private) Supplier<? extends CompletableSource>
CompletableDefer. completableSupplier
(package private) Supplier<? extends T>
CompletableToSingle. completionValueSupplier
(package private) Supplier<? extends java.lang.Throwable>
CompletableErrorSupplier. errorSupplier
(package private) Supplier<R>
CompletableUsing. resourceSupplier
(package private) Supplier<?>
CompletableFromSupplier. supplier
Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type Supplier Constructor Description CompletableDefer(Supplier<? extends CompletableSource> completableSupplier)
CompletableErrorSupplier(Supplier<? extends java.lang.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 class
FlowableEmpty
A source Flowable that signals an onSubscribe() + onComplete() only.class
FlowableFromAction<T>
Executes anAction
and signals its exception or completes normally.class
FlowableFromCallable<T>
class
FlowableFromRunnable<T>
Executes anRunnable
and signals its exception or completes normally.class
FlowableFromSupplier<T>
Call a Supplier for each incoming Subscriber and signal the returned value or the thrown exception.(package private) static class
FlowableInternalHelper.BufferedReplaySupplier<T>
(package private) static class
FlowableInternalHelper.BufferedTimedReplay<T>
(package private) static class
FlowableInternalHelper.ReplaySupplier<T>
(package private) static class
FlowableInternalHelper.TimedReplay<T>
class
FlowableJust<T>
Represents a constant scalar value.(package private) static class
FlowableReplay.DefaultUnboundedFactory
(package private) static class
FlowableReplay.ReplayBufferSupplier<T>
(package private) static class
FlowableReplay.ScheduledReplayBufferSupplier<T>
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as Supplier Modifier and Type Field Description (package private) Supplier<? extends FlowableReplay.ReplayBuffer<T>>
FlowableReplay. bufferFactory
A factory that creates the appropriate buffer for the ReplaySubscriber.private Supplier<? extends FlowableReplay.ReplayBuffer<T>>
FlowableReplay.ReplayPublisher. bufferFactory
(package private) Supplier<C>
FlowableBuffer. bufferSupplier
(package private) Supplier<C>
FlowableBuffer.PublisherBufferExactSubscriber. bufferSupplier
(package private) Supplier<C>
FlowableBuffer.PublisherBufferOverlappingSubscriber. bufferSupplier
(package private) Supplier<C>
FlowableBuffer.PublisherBufferSkipSubscriber. bufferSupplier
(package private) Supplier<C>
FlowableBufferBoundary.BufferBoundarySubscriber. bufferSupplier
(package private) Supplier<U>
FlowableBufferBoundary. bufferSupplier
(package private) Supplier<U>
FlowableBufferExactBoundary.BufferExactBoundarySubscriber. bufferSupplier
(package private) Supplier<U>
FlowableBufferExactBoundary. bufferSupplier
(package private) Supplier<U>
FlowableBufferTimed.BufferExactBoundedSubscriber. bufferSupplier
(package private) Supplier<U>
FlowableBufferTimed.BufferExactUnboundedSubscriber. bufferSupplier
(package private) Supplier<U>
FlowableBufferTimed.BufferSkipBoundedSubscriber. bufferSupplier
(package private) Supplier<U>
FlowableBufferTimed. bufferSupplier
(package private) Supplier<? extends java.util.Collection<? super K>>
FlowableDistinct. collectionSupplier
(package private) Supplier<U>
FlowableToList. collectionSupplier
(package private) Supplier<U>
FlowableToListSingle. collectionSupplier
private Supplier<? extends ConnectableFlowable<U>>
FlowableReplay.MulticastFlowable. connectableFactory
(package private) static Supplier
FlowableReplay. DEFAULT_UNBOUNDED_FACTORY
(package private) Supplier<? extends java.lang.Throwable>
FlowableError. errorSupplier
(package private) Supplier<? extends U>
FlowableCollect. initialSupplier
(package private) Supplier<? extends U>
FlowableCollectSingle. initialSupplier
(package private) Supplier<? extends R>
FlowableMapNotification.MapNotificationSubscriber. onCompleteSupplier
(package private) Supplier<? extends R>
FlowableMapNotification. onCompleteSupplier
(package private) Supplier<? extends D>
FlowableUsing. resourceSupplier
(package private) Supplier<R>
FlowableReduceWithSingle. seedSupplier
(package private) Supplier<R>
FlowableScanSeed. seedSupplier
(package private) Supplier<S>
FlowableGenerate. stateSupplier
(package private) Supplier<? extends org.reactivestreams.Publisher<? extends T>>
FlowableDefer. supplier
(package private) Supplier<? extends T>
FlowableFromSupplier. supplier
(package private) Supplier<R>
FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber. supplier
(package private) Supplier<R>
FlowableOnBackpressureReduceWith. supplier
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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableFlowable<T>>
FlowableInternalHelper. replaySupplier(Flowable<T> parent, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Supplier Modifier and Type Method Description (package private) static <T> ConnectableFlowable<T>
FlowableReplay. create(Flowable<T> source, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
Creates a OperatorReplay instance to replay values of the given sourceFlowable
.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 Constructor Description BackpressureReduceWithSubscriber(@NonNull org.reactivestreams.Subscriber<? super R> downstream, @NonNull Supplier<R> supplier, @NonNull BiFunction<R,? super T,R> reducer)
BufferBoundarySubscriber(org.reactivestreams.Subscriber<? super C> actual, org.reactivestreams.Publisher<? extends Open> bufferOpen, Function<? super Open,? extends org.reactivestreams.Publisher<? extends Close>> bufferClose, Supplier<C> bufferSupplier)
BufferExactBoundarySubscriber(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, org.reactivestreams.Publisher<B> boundary)
BufferExactBoundedSubscriber(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, java.util.concurrent.TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w)
BufferExactUnboundedSubscriber(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
BufferSkipBoundedSubscriber(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler.Worker w)
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, java.util.concurrent.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 java.util.Collection<? super K>> collectionSupplier)
FlowableError(Supplier<? extends java.lang.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 java.lang.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)
FlowableReplay(org.reactivestreams.Publisher<T> onSubscribe, Flowable<T> source, java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> current, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
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)
MapNotificationSubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends R> onNextMapper, Function<? super java.lang.Throwable,? extends R> onErrorMapper, Supplier<? extends R> onCompleteSupplier)
MulticastFlowable(Supplier<? extends ConnectableFlowable<U>> connectableFactory, Function<? super Flowable<U>,? extends org.reactivestreams.Publisher<R>> selector)
PublisherBufferExactSubscriber(org.reactivestreams.Subscriber<? super C> actual, int size, Supplier<C> bufferSupplier)
PublisherBufferOverlappingSubscriber(org.reactivestreams.Subscriber<? super C> actual, int size, int skip, Supplier<C> bufferSupplier)
PublisherBufferSkipSubscriber(org.reactivestreams.Subscriber<? super C> actual, int size, int skip, Supplier<C> bufferSupplier)
ReplayPublisher(java.util.concurrent.atomic.AtomicReference<FlowableReplay.ReplaySubscriber<T>> curr, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)
-
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 class
MaybeEmpty
Signals an onComplete.class
MaybeFromAction<T>
Executes an Action and signals its exception or completes normally.class
MaybeFromCallable<T>
Executes a callable and signals its value as success or signals an exception.class
MaybeFromRunnable<T>
Executes an Runnable and signals its exception or completes normally.class
MaybeFromSupplier<T>
Executes a supplier and signals its value as success or signals an exception.class
MaybeJust<T>
Signals a constant value.Fields in io.reactivex.rxjava3.internal.operators.maybe declared as Supplier Modifier and Type Field Description (package private) Supplier<? extends java.lang.Throwable>
MaybeErrorCallable. errorSupplier
(package private) Supplier<? extends MaybeSource<? extends T>>
MaybeDefer. maybeSupplier
(package private) Supplier<? extends MaybeSource<? extends R>>
MaybeFlatMapNotification.FlatMapMaybeObserver. onCompleteSupplier
(package private) Supplier<? extends MaybeSource<? extends R>>
MaybeFlatMapNotification. onCompleteSupplier
(package private) Supplier<? extends D>
MaybeUsing. resourceSupplier
(package private) Supplier<? extends T>
MaybeFromSupplier. supplier
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type Supplier Constructor Description FlatMapMaybeObserver(MaybeObserver<? super R> actual, Function<? super T,? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super java.lang.Throwable,? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier)
MaybeDefer(Supplier<? extends MaybeSource<? extends T>> maybeSupplier)
MaybeErrorCallable(Supplier<? extends java.lang.Throwable> errorSupplier)
MaybeFlatMapNotification(MaybeSource<T> source, Function<? super T,? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super java.lang.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 class
ObservableEmpty
class
ObservableFromAction<T>
Executes anAction
and signals its exception or completes normally.class
ObservableFromCallable<T>
Calls a Callable and emits its resulting single value or signals its exception.class
ObservableFromRunnable<T>
Executes anRunnable
and signals its exception or completes normally.class
ObservableFromSupplier<T>
Calls a Supplier and emits its resulting single value or signals its exception.(package private) static class
ObservableInternalHelper.BufferedReplaySupplier<T>
(package private) static class
ObservableInternalHelper.BufferedTimedReplaySupplier<T>
(package private) static class
ObservableInternalHelper.ReplaySupplier<T>
(package private) static class
ObservableInternalHelper.TimedReplayCallable<T>
class
ObservableJust<T>
Represents a constant scalar value.Fields in io.reactivex.rxjava3.internal.operators.observable declared as Supplier Modifier and Type Field Description (package private) Supplier<U>
ObservableBuffer.BufferExactObserver. bufferSupplier
(package private) Supplier<U>
ObservableBuffer.BufferSkipObserver. bufferSupplier
(package private) Supplier<U>
ObservableBuffer. bufferSupplier
(package private) Supplier<C>
ObservableBufferBoundary.BufferBoundaryObserver. bufferSupplier
(package private) Supplier<U>
ObservableBufferBoundary. bufferSupplier
(package private) Supplier<U>
ObservableBufferExactBoundary.BufferExactBoundaryObserver. bufferSupplier
(package private) Supplier<U>
ObservableBufferExactBoundary. bufferSupplier
(package private) Supplier<U>
ObservableBufferTimed.BufferExactBoundedObserver. bufferSupplier
(package private) Supplier<U>
ObservableBufferTimed.BufferExactUnboundedObserver. bufferSupplier
(package private) Supplier<U>
ObservableBufferTimed.BufferSkipBoundedObserver. bufferSupplier
(package private) Supplier<U>
ObservableBufferTimed. bufferSupplier
(package private) Supplier<? extends java.util.Collection<? super K>>
ObservableDistinct. collectionSupplier
(package private) Supplier<U>
ObservableToList. collectionSupplier
(package private) Supplier<U>
ObservableToListSingle. collectionSupplier
private Supplier<? extends ConnectableObservable<U>>
ObservableReplay.MulticastReplay. connectableFactory
(package private) Supplier<? extends java.lang.Throwable>
ObservableError. errorSupplier
(package private) Supplier<? extends U>
ObservableCollect. initialSupplier
(package private) Supplier<? extends U>
ObservableCollectSingle. initialSupplier
(package private) Supplier<? extends ObservableSource<? extends R>>
ObservableMapNotification.MapNotificationObserver. onCompleteSupplier
(package private) Supplier<? extends ObservableSource<? extends R>>
ObservableMapNotification. onCompleteSupplier
(package private) Supplier<? extends D>
ObservableUsing. resourceSupplier
(package private) Supplier<R>
ObservableReduceWithSingle. seedSupplier
(package private) Supplier<R>
ObservableScanSeed. seedSupplier
(package private) Supplier<S>
ObservableGenerate. stateSupplier
(package private) Supplier<? extends ObservableSource<? extends T>>
ObservableDefer. supplier
(package private) Supplier<? extends T>
ObservableFromSupplier. supplier
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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>
ObservableInternalHelper. replaySupplier(Observable<T> parent, long time, java.util.concurrent.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.(package private) boolean
ObservableFlatMap.MergeObserver. tryEmitScalar(Supplier<? extends U> value)
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Supplier Constructor Description BufferBoundaryObserver(Observer<? super C> actual, ObservableSource<? extends Open> bufferOpen, Function<? super Open,? extends ObservableSource<? extends Close>> bufferClose, Supplier<C> bufferSupplier)
BufferExactBoundaryObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, ObservableSource<B> boundary)
BufferExactBoundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, java.util.concurrent.TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w)
BufferExactObserver(Observer<? super U> actual, int count, Supplier<U> bufferSupplier)
BufferExactUnboundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
BufferSkipBoundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler.Worker w)
BufferSkipObserver(Observer<? super U> actual, int count, int skip, Supplier<U> bufferSupplier)
MapNotificationObserver(Observer<? super ObservableSource<? extends R>> actual, Function<? super T,? extends ObservableSource<? extends R>> onNextMapper, Function<? super java.lang.Throwable,? extends ObservableSource<? extends R>> onErrorMapper, Supplier<? extends ObservableSource<? extends R>> onCompleteSupplier)
MulticastReplay(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>,? extends ObservableSource<R>> selector)
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, java.util.concurrent.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 java.util.Collection<? super K>> collectionSupplier)
ObservableError(Supplier<? extends java.lang.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 java.lang.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
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as Supplier Modifier and Type Field Description (package private) Supplier<? extends C>
ParallelCollect. initialCollection
(package private) Supplier<R>
ParallelReduce. initialSupplier
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Supplier 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
Classes in io.reactivex.rxjava3.internal.operators.single that implement Supplier Modifier and Type Class Description (package private) static class
SingleInternalHelper.NoSuchElementSupplier
Fields in io.reactivex.rxjava3.internal.operators.single declared as Supplier Modifier and Type Field Description (package private) Supplier<? extends java.lang.Throwable>
SingleError. errorSupplier
(package private) Supplier<U>
SingleUsing. resourceSupplier
(package private) Supplier<? extends SingleSource<? extends T>>
SingleDefer. singleSupplier
(package private) Supplier<? extends T>
SingleFromSupplier. supplier
Methods in io.reactivex.rxjava3.internal.operators.single that return Supplier Modifier and Type Method Description static Supplier<java.util.NoSuchElementException>
SingleInternalHelper. emptyThrower()
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type Supplier Constructor Description SingleDefer(Supplier<? extends SingleSource<? extends T>> singleSupplier)
SingleError(Supplier<? extends java.lang.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 class
ArrayListSupplier
class
HashMapSupplier
Methods in io.reactivex.rxjava3.internal.util that return Supplier Modifier and Type Method Description static <T> Supplier<java.util.List<T>>
ArrayListSupplier. asSupplier()
static <K,V>
Supplier<java.util.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 <@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 acollectionSupplier
and collected into with a collector action, emitting the collection at the end.<@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 aninitialSupplier
value. -
Uses of Supplier in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type Supplier Modifier and Type Field Description (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
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 (package private) static @NonNull Scheduler
RxJavaPlugins. applyRequireNonNull(@NonNull Function<? super Supplier<Scheduler>,? extends Scheduler> f, Supplier<Scheduler> s)
Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.(package private) static @NonNull Scheduler
RxJavaPlugins. callRequireNonNull(@NonNull Supplier<Scheduler> s)
Wraps the call to the Scheduler creation supplier in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.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 (package private) static @NonNull Scheduler
RxJavaPlugins. applyRequireNonNull(@NonNull Function<? super Supplier<Scheduler>,? extends Scheduler> f, Supplier<Scheduler> s)
Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.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. -
Uses of Supplier in io.reactivex.rxjava3.schedulers
Classes in io.reactivex.rxjava3.schedulers that implement Supplier Modifier and Type Class Description (package private) static class
Schedulers.ComputationTask
(package private) static class
Schedulers.IOTask
(package private) static class
Schedulers.NewThreadTask
(package private) static class
Schedulers.SingleTask
-