Uses of Interface
io.reactivex.rxjava3.core.MaybeSource
Packages that use MaybeSource
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Base interfaces and types for supporting operator-fusion.
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
-
Uses of MaybeSource in io.reactivex.rxjava3.core
Classes in io.reactivex.rxjava3.core that implement MaybeSourceModifier and TypeClassDescriptionclass
Maybe<T>
TheMaybe
class represents a deferred computation and emission of a single value, no value at all or an exception.Methods in io.reactivex.rxjava3.core that return MaybeSourceModifier and TypeMethodDescriptionApplies a function to the upstreamMaybe
and returns aMaybeSource
with optionally different element type.Methods in io.reactivex.rxjava3.core with parameters of type MaybeSourceModifier and TypeMethodDescriptionMaybe.ambArray
(@NonNull MaybeSource<? extends @NonNull T>... sources) Runs multipleMaybeSource
s and signals the events of the first one that signals (disposing the rest).Maybe.ambWith
(@NonNull MaybeSource<? extends @NonNull T> other) Mirrors theMaybeSource
(current or provided) that first signals an event.Completable.andThen
(@NonNull MaybeSource<@NonNull T> next) Returns aMaybe
which will subscribe to thisCompletable
and once that is completed then will subscribe to thenext
MaybeSource
.Maybe.concat
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2) Returns aFlowable
that emits the items emitted by twoMaybeSource
s, one after the other.Maybe.concat
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull MaybeSource<? extends @NonNull T> source3) Returns aFlowable
that emits the items emitted by threeMaybeSource
s, one after the other.Maybe.concat
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull MaybeSource<? extends @NonNull T> source3, @NonNull MaybeSource<? extends @NonNull T> source4) Returns aFlowable
that emits the items emitted by fourMaybeSource
s, one after the other.Maybe.concatArray
(@NonNull MaybeSource<? extends @NonNull T>... sources) Concatenate the single values, in a non-overlapping fashion, of theMaybeSource
sources in the array as aFlowable
sequence.Maybe.concatArrayDelayError
(@NonNull MaybeSource<? extends @NonNull T>... sources) Concatenates a variable number ofMaybeSource
sources and delays errors from any of them till all terminate as aFlowable
sequence.Maybe.concatArrayEager
(@NonNull MaybeSource<? extends @NonNull T>... sources) Concatenates a sequence ofMaybeSource
eagerly into aFlowable
sequence.Maybe.concatArrayEagerDelayError
(@NonNull MaybeSource<? extends @NonNull T>... sources) Concatenates a sequence ofMaybeSource
eagerly into aFlowable
sequence.Flowable.concatWith
(@NonNull MaybeSource<? extends @NonNull T> other) Returns aFlowable
that emits the items from thisFlowable
followed by the success item or terminal events of the otherMaybeSource
.Maybe.concatWith
(@NonNull MaybeSource<? extends @NonNull T> other) Returns aFlowable
that emits the items emitted from the currentMaybe
, then theother
MaybeSource
, one after the other, without interleaving them.final @NonNull Observable
<T> Observable.concatWith
(@NonNull MaybeSource<? extends @NonNull T> other) Returns anObservable
that emits the items from the currentObservable
followed by the success item or terminal events of the otherMaybeSource
.static <@NonNull T>
@NonNull CompletableCompletable.fromMaybe
(@NonNull MaybeSource<@NonNull T> maybe) Returns aCompletable
instance that when subscribed to, subscribes to theMaybeSource
instance and emits anonComplete
event if the maybe emitsonSuccess
/onComplete
or forwards anyonError
events.Flowable.fromMaybe
(@NonNull MaybeSource<@NonNull T> maybe) Returns aFlowable
instance that when subscribed to, subscribes to theMaybeSource
instance and emitsonSuccess
as a single item or forwards anyonComplete
oronError
signal.static <@NonNull T>
@NonNull Observable<T> Observable.fromMaybe
(@NonNull MaybeSource<@NonNull T> maybe) Returns anObservable
instance that when subscribed to, subscribes to theMaybeSource
instance and emitsonSuccess
as a single item or forwards anyonComplete
oronError
signal.Single.fromMaybe
(@NonNull MaybeSource<@NonNull T> maybe) Returns aSingle
instance that when subscribed to, subscribes to theMaybeSource
instance and emitsonSuccess
as a single item, turns anonComplete
intoNoSuchElementException
error signal or forwards theonError
signal.Single.fromMaybe
(@NonNull MaybeSource<@NonNull T> maybe, @NonNull T defaultItem) Returns aSingle
instance that when subscribed to, subscribes to theMaybeSource
instance and emitsonSuccess
as a single item, emits thedefaultItem
for anonComplete
signal or forwards theonError
signal.Maybe.merge
(@NonNull MaybeSource<? extends MaybeSource<? extends @NonNull T>> source) Flattens aMaybeSource
that emits aMaybeSource
into a singleMaybeSource
that emits the item emitted by the nestedMaybeSource
, without any transformation.Maybe.merge
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2) Flattens twoMaybeSource
s into a singleFlowable
, without any transformation.Maybe.merge
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull MaybeSource<? extends @NonNull T> source3) Flattens threeMaybeSource
s into a singleFlowable
, without any transformation.Maybe.merge
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull MaybeSource<? extends @NonNull T> source3, @NonNull MaybeSource<? extends @NonNull T> source4) Flattens fourMaybeSource
s into a singleFlowable
, without any transformation.Maybe.mergeArray
(MaybeSource<? extends @NonNull T>... sources) Merges an array ofMaybeSource
instances into a singleFlowable
sequence, running allMaybeSource
s at once.Maybe.mergeArrayDelayError
(@NonNull MaybeSource<? extends @NonNull T>... sources) Flattens an array ofMaybeSource
s into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from each of the sourceMaybeSource
s without being interrupted by an error notification from one of them.Maybe.mergeDelayError
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2) Flattens twoMaybeSource
s into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from each of the sourceMaybeSource
s without being interrupted by an error notification from one of them.Maybe.mergeDelayError
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull MaybeSource<? extends @NonNull T> source3) Flattens threeMaybeSource
into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from all of the sourceMaybeSource
s without being interrupted by an error notification from one of them.Maybe.mergeDelayError
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull MaybeSource<? extends @NonNull T> source3, @NonNull MaybeSource<? extends @NonNull T> source4) Flattens fourMaybeSource
s into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from all of the sourceMaybeSource
s without being interrupted by an error notification from one of them.Flowable.mergeWith
(@NonNull MaybeSource<? extends @NonNull T> other) Merges the sequence of items of thisFlowable
with the success value of the otherMaybeSource
or waits for both to complete normally if theMaybeSource
is empty.Maybe.mergeWith
(@NonNull MaybeSource<? extends @NonNull T> other) final @NonNull Observable
<T> Observable.mergeWith
(@NonNull MaybeSource<? extends @NonNull T> other) Merges the sequence of items of the currentObservable
with the success value of the otherMaybeSource
or waits both to complete normally if theMaybeSource
is empty.Maybe.onErrorResumeWith
(@NonNull MaybeSource<? extends @NonNull T> fallback) Resumes the flow with the givenMaybeSource
when the currentMaybe
fails instead of signaling the error viaonError
.Maybe.sequenceEqual
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2) Returns aSingle
that emits aBoolean
value that indicates whether twoMaybeSource
sequences are the same by comparing the items emitted by eachMaybeSource
pairwise.Maybe.sequenceEqual
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T, ? super @NonNull T> isEqual) Returns aSingle
that emits aBoolean
value that indicates whether twoMaybeSource
s are the same by comparing the items emitted by eachMaybeSource
pairwise based on the results of a specified equality function.Completable.startWith
(@NonNull MaybeSource<@NonNull T> other) Returns aFlowable
which first runs the otherMaybeSource
then the currentCompletable
if the other succeeded or completed normally.Flowable.startWith
(@NonNull MaybeSource<@NonNull T> other) Returns aFlowable
which first runs the otherMaybeSource
then the currentFlowable
if the other succeeded or completed normally.Maybe.startWith
(@NonNull MaybeSource<@NonNull T> other) Returns aFlowable
which first runs the otherMaybeSource
then the currentMaybe
if the other succeeded or completed normally.final @NonNull Observable
<T> Observable.startWith
(@NonNull MaybeSource<@NonNull T> other) Returns anObservable
which first runs the otherMaybeSource
then the currentObservable
if the other succeeded or completed normally.Single.startWith
(@NonNull MaybeSource<@NonNull T> other) Returns aFlowable
which first runs the otherMaybeSource
then the currentSingle
if the other succeeded or completed normally.Maybe.switchIfEmpty
(@NonNull MaybeSource<? extends @NonNull T> other) Returns aMaybe
that emits the items emitted by the currentMaybe
or the items of an alternateMaybeSource
if the currentMaybe
is empty.Maybe.takeUntil
(@NonNull MaybeSource<@NonNull U> other) Returns aMaybe
that emits the items emitted by the currentMaybe
until a secondMaybeSource
emits an item.Maybe.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull MaybeSource<? extends @NonNull T> fallback) Returns aMaybe
that mirrors the currentMaybe
but applies a timeout policy for each emitted item.Maybe.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull MaybeSource<? extends @NonNull T> fallback) Returns aMaybe
that mirrors the currentMaybe
but applies a timeout policy for each emitted item using a specifiedScheduler
.Maybe.timeout
(@NonNull MaybeSource<@NonNull U> timeoutIndicator) If the currentMaybe
didn't signal an event before thetimeoutIndicator
MaybeSource
signals, aTimeoutException
is signaled instead.Maybe.timeout
(@NonNull MaybeSource<@NonNull U> timeoutIndicator, @NonNull MaybeSource<? extends @NonNull T> fallback) If the currentMaybe
didn't signal an event before thetimeoutIndicator
MaybeSource
signals, the currentMaybe
is disposed and thefallback
MaybeSource
subscribed to as a continuation.Maybe.timeout
(@NonNull org.reactivestreams.Publisher<@NonNull U> timeoutIndicator, @NonNull MaybeSource<? extends @NonNull T> fallback) If the currentMaybe
didn't signal an event before thetimeoutIndicator
Publisher
signals, the currentMaybe
is disposed and thefallback
MaybeSource
subscribed to as a continuation.Maybe.unsafeCreate
(@NonNull MaybeSource<@NonNull T> onSubscribe) Advanced use only: creates aMaybe
instance without any safeguards by using a callback that is called with aMaybeObserver
.Maybe.wrap
(@NonNull MaybeSource<@NonNull T> source) static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull T8, @NonNull T9, @NonNull R>
@NonNull Maybe<R> Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull MaybeSource<? extends @NonNull T4> source4, @NonNull MaybeSource<? extends @NonNull T5> source5, @NonNull MaybeSource<? extends @NonNull T6> source6, @NonNull MaybeSource<? extends @NonNull T7> source7, @NonNull MaybeSource<? extends @NonNull T8> source8, @NonNull MaybeSource<? extends @NonNull T9> source9, @NonNull Function9<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? super @NonNull T8, ? super @NonNull T9, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of nine items emitted, in sequence, by nine otherMaybeSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull T8, @NonNull R>
@NonNull Maybe<R> Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull MaybeSource<? extends @NonNull T4> source4, @NonNull MaybeSource<? extends @NonNull T5> source5, @NonNull MaybeSource<? extends @NonNull T6> source6, @NonNull MaybeSource<? extends @NonNull T7> source7, @NonNull MaybeSource<? extends @NonNull T8> source8, @NonNull Function8<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? super @NonNull T8, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of eight items emitted, in sequence, by eight otherMaybeSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull R>
@NonNull Maybe<R> Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull MaybeSource<? extends @NonNull T4> source4, @NonNull MaybeSource<? extends @NonNull T5> source5, @NonNull MaybeSource<? extends @NonNull T6> source6, @NonNull MaybeSource<? extends @NonNull T7> source7, @NonNull Function7<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of seven items emitted, in sequence, by seven otherMaybeSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull R>
@NonNull Maybe<R> Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull MaybeSource<? extends @NonNull T4> source4, @NonNull MaybeSource<? extends @NonNull T5> source5, @NonNull MaybeSource<? extends @NonNull T6> source6, @NonNull Function6<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of six items emitted, in sequence, by six otherMaybeSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull R>
@NonNull Maybe<R> Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull MaybeSource<? extends @NonNull T4> source4, @NonNull MaybeSource<? extends @NonNull T5> source5, @NonNull Function5<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of five items emitted, in sequence, by five otherMaybeSource
s.Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull MaybeSource<? extends @NonNull T4> source4, @NonNull Function4<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of four items emitted, in sequence, by four otherMaybeSource
s.Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull MaybeSource<? extends @NonNull T3> source3, @NonNull Function3<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of three items emitted, in sequence, by three otherMaybeSource
s.Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherMaybeSource
s.Maybe.zipArray
(@NonNull Function<? super Object[], ? extends @NonNull R> zipper, @NonNull MaybeSource<? extends @NonNull T>... sources) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an array of otherMaybeSource
s.Maybe.zipWith
(@NonNull MaybeSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Waits until this and the otherMaybeSource
signal a success value then applies the givenBiFunction
to those values and emits theBiFunction
's resulting value to downstream.Method parameters in io.reactivex.rxjava3.core with type arguments of type MaybeSourceModifier and TypeMethodDescriptionRuns multipleMaybeSource
s provided by anIterable
sequence and signals the events of the first one that signals (disposing the rest).Concatenate the single values, in a non-overlapping fashion, of theMaybeSource
sources provided by anIterable
sequence as aFlowable
sequence.Maybe.concat
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Concatenate the single values, in a non-overlapping fashion, of theMaybeSource
sources provided by aPublisher
sequence as aFlowable
sequence.Maybe.concat
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int prefetch) Concatenate the single values, in a non-overlapping fashion, of theMaybeSource
sources provided by aPublisher
sequence as aFlowable
sequence.Maybe.concatDelayError
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Concatenates theIterable
sequence ofMaybeSource
s into a single sequence by subscribing to eachMaybeSource
, one after the other, one at a time and delays any errors till the all innerMaybeSource
s terminate as aFlowable
sequence.Maybe.concatDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Concatenates thePublisher
sequence ofMaybeSource
s into a single sequence by subscribing to each innerMaybeSource
, one after the other, one at a time and delays any errors till the all inner and the outerPublisher
terminate as aFlowable
sequence.Maybe.concatDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int prefetch) Concatenates thePublisher
sequence ofMaybeSource
s into a single sequence by subscribing to each innerMaybeSource
, one after the other, one at a time and delays any errors till the all inner and the outerPublisher
terminate as aFlowable
sequence.Maybe.concatEager
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Concatenates a sequence ofMaybeSource
s eagerly into aFlowable
sequence.Maybe.concatEager
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int maxConcurrency) Concatenates a sequence ofMaybeSource
s eagerly into aFlowable
sequence and runs a limited number of the inner sequences at once.Maybe.concatEager
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Maybe.concatEager
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int maxConcurrency) Concatenates aPublisher
sequence ofMaybeSource
s eagerly into aFlowable
sequence, running at most the given number of innerMaybeSource
s at once.Maybe.concatEagerDelayError
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Concatenates a sequence ofMaybeSource
s eagerly into aFlowable
sequence, delaying errors until all innerMaybeSource
s terminate.Maybe.concatEagerDelayError
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int maxConcurrency) Concatenates a sequence ofMaybeSource
s eagerly into aFlowable
sequence, delaying errors until all innerMaybeSource
s terminate and runs a limited number of innerMaybeSource
s at once.Maybe.concatEagerDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Concatenates aPublisher
sequence ofMaybeSource
s eagerly into aFlowable
sequence, delaying errors until all the inner and the outer sequence terminate.Maybe.concatEagerDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int maxConcurrency) Concatenates aPublisher
sequence ofMaybeSource
s eagerly into aFlowable
sequence, delaying errors until all the inner and the outer sequence terminate and runs a limited number of the innerMaybeSource
s at once.Maybe.concatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aMaybeSource
.Flowable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either thisFlowable
or the current innerMaybeSource
fail.Flowable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, int prefetch) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either thisFlowable
or the current innerMaybeSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either the currentObservable
or the current innerMaybeSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, int bufferSize) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either the currentObservable
or the current innerMaybeSource
fail.Single.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns aMaybeSource
.Flowable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and delaying all errors till both thisFlowable
and all innerMaybeSource
s terminate.Flowable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both thisFlowable
and all innerMaybeSource
s terminate.Flowable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int prefetch) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both thisFlowable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.Calls aSupplier
for each individualMaybeObserver
to return the actualMaybeSource
source to be subscribed to.Maybe.flatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aMaybeSource
.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 theonSuccess
,onError
oronComplete
signals of the currentMaybe
into aMaybeSource
and emits thatMaybeSource
's signals.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 theonSuccess
,onError
oronComplete
signals of the currentMaybe
into aMaybeSource
and emits thatMaybeSource
's signals.Maybe.flatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Returns aMaybe
that emits the results of a specified function to the pair of values emitted by the currentMaybe
and a specified mappedMaybeSource
.Flowable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps each element of the upstreamFlowable
intoMaybeSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleFlowable
sequence.Flowable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency) Maps each element of the upstreamFlowable
intoMaybeSource
s, subscribes to at mostmaxConcurrency
MaybeSource
s at a time and merges theironSuccess
values, in no particular order, into a singleFlowable
sequence, optionally delaying all errors.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps each element of the currentObservable
intoMaybeSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean delayErrors) Maps each element of the currentObservable
intoMaybeSource
s, subscribes to them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence, optionally delaying all errors.Single.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns aMaybeSource
.Maybe.merge
(@NonNull MaybeSource<? extends MaybeSource<? extends @NonNull T>> source) Flattens aMaybeSource
that emits aMaybeSource
into a singleMaybeSource
that emits the item emitted by the nestedMaybeSource
, without any transformation.Merges anIterable
sequence ofMaybeSource
instances into a singleFlowable
sequence, running allMaybeSource
s at once.Maybe.merge
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Merges aPublisher
sequence ofMaybeSource
instances into a singleFlowable
sequence, running allMaybeSource
s at once.Maybe.merge
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int maxConcurrency) Merges aPublisher
sequence ofMaybeSource
instances into a singleFlowable
sequence, running at most maxConcurrencyMaybeSource
s at once.Maybe.mergeDelayError
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Flattens anIterable
sequence ofMaybeSource
s into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from each of the sourceMaybeSource
s without being interrupted by an error notification from one of them.Maybe.mergeDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Flattens aPublisher
that emitsMaybeSource
s into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from all of the sourceMaybeSource
s without being interrupted by an error notification from one of them or even the mainPublisher
.Maybe.mergeDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, int maxConcurrency) Flattens aPublisher
that emitsMaybeSource
s into oneFlowable
, in a way that allows a subscriber to receive all successfully emitted items from all of the sourceMaybeSource
s without being interrupted by an error notification from one of them or even the mainPublisher
as well as limiting the total number of activeMaybeSource
s.Maybe.onErrorResumeNext
(@NonNull Function<? super Throwable, ? extends MaybeSource<? extends @NonNull T>> fallbackSupplier) Resumes the flow with aMaybeSource
returned for the failureThrowable
of the currentMaybe
by a function instead of signaling the error viaonError
.Flowable.switchMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available while failing immediately if thisFlowable
or any of the active innerMaybeSource
s fail.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the items of the currentObservable
intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available while failing immediately if the currentObservable
or any of the active innerMaybeSource
s fail.Flowable.switchMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available, delaying errors from thisFlowable
or the innerMaybeSource
s until all terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available, delaying errors from the currentObservable
or the innerMaybeSource
s until all terminate.Maybe.switchOnNext
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Switches betweenMaybeSource
s emitted by the sourcePublisher
whenever a newMaybeSource
is emitted, disposing the previously runningMaybeSource
, exposing the success items as aFlowable
sequence.Maybe.switchOnNextDelayError
(@NonNull org.reactivestreams.Publisher<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources) Switches betweenMaybeSource
s emitted by the sourcePublisher
whenever a newMaybeSource
is emitted, disposing the previously runningMaybeSource
, exposing the success items as aFlowable
sequence and delaying all errors from all of them until all terminate.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().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}).Maybe.zip
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherMaybeSource
s. -
Uses of MaybeSource in io.reactivex.rxjava3.internal.fuseable
Methods in io.reactivex.rxjava3.internal.fuseable that return MaybeSourceModifier and TypeMethodDescriptionHasUpstreamMaybeSource.source()
Returns the upstream source of this Maybe. -
Uses of MaybeSource in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement MaybeSourceModifier and TypeClassDescriptionfinal class
Wrap a CompletionStage and signal its outcome.final class
MaybeMapOptional<T,
R> Maps the success value to anOptional
and emits its non-empty value or completes.final class
SingleMapOptional<T,
R> Maps the success value to anOptional
and emits its non-empty value or completes. -
Uses of MaybeSource in io.reactivex.rxjava3.internal.operators.completable
Classes in io.reactivex.rxjava3.internal.operators.completable that implement MaybeSourceModifier and TypeClassDescriptionfinal class
Returns a value generated via a function if the main source signals an onError. -
Uses of MaybeSource in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement MaybeSourceModifier and TypeClassDescriptionfinal class
final class
Emits the indexth element from a Publisher as a Maybe.final class
Consumes the source Publisher and emits its last item or completes.final class
Reduce a Flowable into a single value exposed as Single or signal NoSuchElementException.final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as MaybeSourceModifier and TypeFieldDescription(package private) MaybeSource
<? extends T> FlowableConcatWithMaybe.ConcatWithSubscriber.other
(package private) final MaybeSource
<? extends T> FlowableConcatWithMaybe.other
(package private) final MaybeSource
<? extends T> FlowableMergeWithMaybe.other
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type MaybeSourceModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableFlatMapMaybe.FlatMapMaybeSubscriber.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableFlatMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableFlatMapMaybePublisher.mapper
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type MaybeSourceModifierConstructorDescription(package private)
ConcatWithSubscriber
(org.reactivestreams.Subscriber<? super T> actual, MaybeSource<? extends T> other) FlowableConcatWithMaybe
(Flowable<T> source, MaybeSource<? extends T> other) FlowableMergeWithMaybe
(Flowable<T> source, MaybeSource<? extends T> other) Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type MaybeSourceModifierConstructorDescription(package private)
FlatMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors, int maxConcurrency) FlowableFlatMapMaybe
(Flowable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayError, int maxConcurrency) FlowableFlatMapMaybePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayError, int maxConcurrency) -
Uses of MaybeSource in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement MaybeSourceModifier and TypeClassDescription(package private) class
Abstract base class for intermediate Maybe operators that take an upstream MaybeSource.final class
MaybeAmb<T>
Signals the event of the first MaybeSource that signals.final class
MaybeCache<T>
Consumes the source once and replays its signal to any current or future MaybeObservers.final class
MaybeCreate<T>
Provides an API over MaybeObserver that serializes calls to onXXX and manages cancellation in a safe manner.final class
MaybeDefer<T>
Defers the creation of the actual Maybe the incoming MaybeObserver is subscribed to.final class
MaybeDelay<T>
Delays all signal types by the given amount and re-emits them on the given scheduler.final class
Delay the emission of the main signal until the other signals an item or completes.final class
Delay the subscription to the main Maybe until the other signals an item or completes.final class
final class
MaybeDematerialize<T,
R> Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.final class
MaybeDetach<T>
Breaks the references between the upstream and downstream when the Maybe terminates.final class
Calls a consumer after pushing the current item to the downstream.final class
Execute an action after an onSuccess, onError, onComplete or a dispose event.final class
Calls a BiConsumer with the success, error values of the upstream Maybe or with two nulls if the Maybe completed.final class
Invokes callbacks upononSubscribe
from upstream anddispose
from downstream.final class
final class
Signals an onComplete.final class
MaybeError<T>
Signals a constant Throwable.final class
Signals a Throwable returned by a Supplier.final class
MaybeFilter<T>
Filters the upstream via a predicate, returning the success item or completing if the predicate returns false.final class
Filters the upstream SingleSource via a predicate, returning the success item or completing if the predicate returns false.final class
MaybeFlatMapBiSelector<T,
U, R> Maps a source item to another MaybeSource then calls a BiFunction with the original item and the secondary item to generate the final result.final class
Maps a value into a MaybeSource and relays its signal.final class
MaybeFlatMapSingle<T,
R> Maps the success value of the source MaybeSource into a Single.final class
MaybeFlatten<T,
R> Maps a value into a MaybeSource and relays its signal.final class
Executes an Action and signals its exception or completes normally.final class
Executes a callable and signals its value as success or signals an exception.final class
Wrap a Completable into a Maybe.final class
Waits until the source Future completes or the wait times out; treats anull
result as indication to signalonComplete
instead ofonSuccess
.final class
Executes an Runnable and signals its exception or completes normally.final class
Wrap a Single into a Maybe.final class
Executes a supplier and signals its value as success or signals an exception.final class
MaybeHide<T>
Hides the identity of the upstream Maybe and its Disposable sent through onSubscribe.final class
Turns an onSuccess into an onComplete, onError and onComplete is relayed as is.final class
MaybeIsEmpty<T>
Signals true if the source Maybe signals onComplete, signals false if the source Maybe signals onSuccess.final class
MaybeJust<T>
Signals a constant value.final class
MaybeLift<T,
R> Calls a MaybeOperator for the incoming MaybeObserver.final class
MaybeMap<T,
R> Maps the upstream success value into some other value.final class
Doesn't signal any event other than onSubscribe.final class
Signals the onSuccess, onError or onComplete events on a the specific scheduler.final class
Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.final class
Subscribes to the MaybeSource returned by a function if the main source signals an onError.final class
Returns a value generated via a function if the main source signals an onError.final class
MaybePeek<T>
Peeks into the lifecycle of a Maybe and MaybeObserver.final class
Subscribes to the upstream MaybeSource on the specified scheduler.final class
Subscribes to the other source if the main source is empty.final class
MaybeTakeUntilMaybe<T,
U> Relays the main source's event unless the other Maybe signals an item first or just completes at which point the resulting Maybe is completed.final class
Relays the main source's event unless the other Publisher signals an item first or just completes at which point the resulting Maybe is completed.final class
Measures the time between subscription and the success item emission from the upstream and emits this as aTimed
success value.final class
MaybeTimeoutMaybe<T,
U> Switches to the fallback Maybe if the other MaybeSource signals a success or completes, or signals TimeoutException if fallback is null.final class
Switches to the fallback Maybe if the other Publisher signals a success or completes, or signals TimeoutException if fallback is null.final class
Signals a0L
after the specified delay.final class
Wraps a MaybeSource without safeguard and calls its subscribe() method for each MaybeObserver.final class
Makes sure a dispose() call from downstream happens on the specified scheduler.final class
MaybeUsing<T,
D> Creates a resource and a dependent Maybe for each incoming Observer and optionally disposes the resource eagerly (before the terminal event is send out).final class
MaybeZipArray<T,
R> final class
MaybeZipIterable<T,
R> Fields in io.reactivex.rxjava3.internal.operators.maybe declared as MaybeSourceModifier and TypeFieldDescription(package private) final MaybeSource
<? extends T> MaybeTimeoutMaybe.fallback
(package private) final MaybeSource
<? extends T> MaybeTimeoutMaybe.TimeoutMainMaybeObserver.fallback
(package private) final MaybeSource
<? extends T> MaybeTimeoutPublisher.fallback
(package private) final MaybeSource
<? extends T> MaybeTimeoutPublisher.TimeoutMainMaybeObserver.fallback
(package private) final MaybeSource
<? extends T> MaybeSwitchIfEmpty.other
(package private) final MaybeSource
<? extends T> MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver.other
(package private) final MaybeSource
<U> MaybeTakeUntilMaybe.other
(package private) final MaybeSource
<U> MaybeTimeoutMaybe.other
protected final MaybeSource
<T> AbstractMaybeWithUpstream.source
(package private) final MaybeSource
<T> MaybeContains.source
(package private) final MaybeSource
<T> MaybeCount.source
(package private) MaybeSource
<T> MaybeDelaySubscriptionOtherPublisher.OtherSubscriber.source
(package private) final MaybeSource
<T> MaybeDelayWithCompletable.OtherObserver.source
(package private) final MaybeSource
<T> MaybeDelayWithCompletable.source
(package private) final MaybeSource
<T> MaybeDoOnTerminate.source
(package private) final MaybeSource
<T> MaybeFlatMapCompletable.source
(package private) final MaybeSource
<T> MaybeFlatMapIterableFlowable.source
(package private) final MaybeSource
<T> MaybeFlatMapIterableObservable.source
(package private) final MaybeSource
<T> MaybeFlatMapSingle.source
(package private) final MaybeSource
<T> MaybeIgnoreElementCompletable.source
(package private) final MaybeSource
<T> MaybeIsEmptySingle.source
(package private) final MaybeSource
<T> MaybeSubscribeOn.SubscribeTask.source
(package private) final MaybeSource
<T> MaybeSwitchIfEmptySingle.source
(package private) final MaybeSource
<T> MaybeTimeInterval.source
(package private) final MaybeSource
<T> MaybeToFlowable.source
(package private) final MaybeSource
<T> MaybeToObservable.source
(package private) final MaybeSource
<T> MaybeToSingle.source
(package private) final MaybeSource
<? extends T> MaybeEqualSingle.source1
(package private) final MaybeSource
<? extends T> MaybeEqualSingle.source2
private final MaybeSource<? extends T>[]
MaybeAmb.sources
(package private) final MaybeSource<? extends T>[]
MaybeConcatArray.ConcatMaybeObserver.sources
(package private) final MaybeSource<? extends T>[]
MaybeConcatArray.sources
(package private) final MaybeSource<? extends T>[]
MaybeConcatArrayDelayError.ConcatMaybeObserver.sources
(package private) final MaybeSource<? extends T>[]
MaybeConcatArrayDelayError.sources
(package private) final MaybeSource<? extends T>[]
MaybeMergeArray.sources
(package private) final MaybeSource<? extends T>[]
MaybeZipArray.sources
Fields in io.reactivex.rxjava3.internal.operators.maybe with type parameters of type MaybeSourceModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends MaybeSource<? extends U>> MaybeFlatMapBiSelector.FlatMapBiMainObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends U>> MaybeFlatMapBiSelector.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatten.FlatMapMaybeObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatten.mapper
(package private) final Supplier
<? extends MaybeSource<? extends T>> MaybeDefer.maybeSupplier
(package private) final Supplier
<? extends MaybeSource<? extends R>> MaybeFlatMapNotification.FlatMapMaybeObserver.onCompleteSupplier
(package private) final Supplier
<? extends MaybeSource<? extends R>> MaybeFlatMapNotification.onCompleteSupplier
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.FlatMapMaybeObserver.onErrorMapper
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.onErrorMapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.FlatMapMaybeObserver.onSuccessMapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.onSuccessMapper
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends T>> MaybeOnErrorNext.OnErrorNextMaybeObserver.resumeFunction
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends T>> MaybeOnErrorNext.resumeFunction
(package private) final AtomicReference
<MaybeSource<T>> MaybeCache.source
(package private) final Iterator
<? extends MaybeSource<? extends T>> MaybeConcatIterable.ConcatMaybeObserver.sources
(package private) final Iterable
<? extends MaybeSource<? extends T>> MaybeConcatIterable.sources
(package private) final Iterable
<? extends MaybeSource<? extends T>> MaybeZipIterable.sources
private final Iterable
<? extends MaybeSource<? extends T>> MaybeAmb.sourcesIterable
(package private) final Function
<? super D, ? extends MaybeSource<? extends T>> MaybeUsing.sourceSupplier
Methods in io.reactivex.rxjava3.internal.operators.maybe that return MaybeSourceModifier and TypeMethodDescriptionfinal MaybeSource
<T> AbstractMaybeWithUpstream.source()
MaybeContains.source()
MaybeCount.source()
MaybeIsEmptySingle.source()
MaybeSwitchIfEmptySingle.source()
MaybeToFlowable.source()
MaybeToObservable.source()
MaybeToSingle.source()
Methods in io.reactivex.rxjava3.internal.operators.maybe that return types with arguments of type MaybeSourceModifier and TypeMethodDescriptionstatic <T> Function
<MaybeSource<T>, org.reactivestreams.Publisher<T>> MaybeToPublisher.instance()
Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type MaybeSourceModifier and TypeMethodDescriptionorg.reactivestreams.Publisher
<Object> MaybeToPublisher.apply
(MaybeSource<Object> t) (package private) void
MaybeEqualSingle.EqualCoordinator.subscribe
(MaybeSource<? extends T> source1, MaybeSource<? extends T> source2) Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type MaybeSourceModifierConstructorDescription(package private)
AbstractMaybeWithUpstream
(MaybeSource<T> source) (package private)
ConcatMaybeObserver
(org.reactivestreams.Subscriber<? super T> actual, MaybeSource<? extends T>[] sources) (package private)
ConcatMaybeObserver
(org.reactivestreams.Subscriber<? super T> actual, MaybeSource<? extends T>[] sources) MaybeAmb
(MaybeSource<? extends T>[] sources, Iterable<? extends MaybeSource<? extends T>> sourcesIterable) MaybeCache
(MaybeSource<T> source) MaybeConcatArray
(MaybeSource<? extends T>[] sources) MaybeConcatArrayDelayError
(MaybeSource<? extends T>[] sources) MaybeContains
(MaybeSource<T> source, Object value) MaybeCount
(MaybeSource<T> source) MaybeDelay
(MaybeSource<T> source, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) MaybeDelayOtherPublisher
(MaybeSource<T> source, org.reactivestreams.Publisher<U> other) MaybeDelaySubscriptionOtherPublisher
(MaybeSource<T> source, org.reactivestreams.Publisher<U> other) MaybeDelayWithCompletable
(MaybeSource<T> source, CompletableSource other) MaybeDetach
(MaybeSource<T> source) MaybeDoAfterSuccess
(MaybeSource<T> source, Consumer<? super T> onAfterSuccess) MaybeDoFinally
(MaybeSource<T> source, Action onFinally) MaybeDoOnEvent
(MaybeSource<T> source, BiConsumer<? super T, ? super Throwable> onEvent) MaybeDoOnTerminate
(MaybeSource<T> source, Action onTerminate) MaybeEqualSingle
(MaybeSource<? extends T> source1, MaybeSource<? extends T> source2, BiPredicate<? super T, ? super T> isEqual) MaybeFilter
(MaybeSource<T> source, Predicate<? super T> predicate) MaybeFlatMapBiSelector
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) MaybeFlatMapCompletable
(MaybeSource<T> source, Function<? super T, ? extends CompletableSource> mapper) MaybeFlatMapIterableFlowable
(MaybeSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) MaybeFlatMapIterableObservable
(MaybeSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) 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) MaybeFlatMapSingle
(MaybeSource<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper) MaybeFlatten
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper) MaybeHide
(MaybeSource<T> source) MaybeIgnoreElement
(MaybeSource<T> source) MaybeIgnoreElementCompletable
(MaybeSource<T> source) MaybeIsEmpty
(MaybeSource<T> source) MaybeIsEmptySingle
(MaybeSource<T> source) MaybeLift
(MaybeSource<T> source, MaybeOperator<? extends R, ? super T> operator) MaybeMergeArray
(MaybeSource<? extends T>[] sources) MaybeObserveOn
(MaybeSource<T> source, Scheduler scheduler) MaybeOnErrorComplete
(MaybeSource<T> source, Predicate<? super Throwable> predicate) MaybeOnErrorNext
(MaybeSource<T> source, Function<? super Throwable, ? extends MaybeSource<? extends T>> resumeFunction) MaybeOnErrorReturn
(MaybeSource<T> source, Function<? super Throwable, ? extends T> itemSupplier) MaybePeek
(MaybeSource<T> source, Consumer<? super Disposable> onSubscribeCall, Consumer<? super T> onSuccessCall, Consumer<? super Throwable> onErrorCall, Action onCompleteCall, Action onAfterTerminate, Action onDispose) MaybeSubscribeOn
(MaybeSource<T> source, Scheduler scheduler) MaybeSwitchIfEmpty
(MaybeSource<T> source, MaybeSource<? extends T> other) MaybeSwitchIfEmptySingle
(MaybeSource<T> source, SingleSource<? extends T> other) MaybeTakeUntilMaybe
(MaybeSource<T> source, MaybeSource<U> other) MaybeTakeUntilPublisher
(MaybeSource<T> source, org.reactivestreams.Publisher<U> other) MaybeTimeInterval
(MaybeSource<T> source, TimeUnit unit, Scheduler scheduler, boolean start) MaybeTimeoutMaybe
(MaybeSource<T> source, MaybeSource<U> other, MaybeSource<? extends T> fallback) MaybeTimeoutPublisher
(MaybeSource<T> source, org.reactivestreams.Publisher<U> other, MaybeSource<? extends T> fallback) MaybeToFlowable
(MaybeSource<T> source) MaybeToObservable
(MaybeSource<T> source) MaybeToSingle
(MaybeSource<T> source, T defaultValue) MaybeUnsafeCreate
(MaybeSource<T> source) MaybeUnsubscribeOn
(MaybeSource<T> source, Scheduler scheduler) MaybeZipArray
(MaybeSource<? extends T>[] sources, Function<? super Object[], ? extends R> zipper) (package private)
OtherObserver
(MaybeObserver<? super T> actual, MaybeSource<T> source) (package private)
OtherSubscriber
(MaybeObserver<? super T> actual, MaybeSource<T> source) (package private)
SubscribeTask
(MaybeObserver<? super T> observer, MaybeSource<T> source) (package private)
SwitchIfEmptyMaybeObserver
(MaybeObserver<? super T> actual, MaybeSource<? extends T> other) (package private)
TimeoutMainMaybeObserver
(MaybeObserver<? super T> actual, MaybeSource<? extends T> fallback) (package private)
TimeoutMainMaybeObserver
(MaybeObserver<? super T> actual, MaybeSource<? extends T> fallback) Constructor parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type MaybeSourceModifierConstructorDescription(package private)
ConcatMaybeObserver
(org.reactivestreams.Subscriber<? super T> actual, Iterator<? extends MaybeSource<? extends T>> sources) (package private)
FlatMapBiMainObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper) MaybeAmb
(MaybeSource<? extends T>[] sources, Iterable<? extends MaybeSource<? extends T>> sourcesIterable) MaybeConcatIterable
(Iterable<? extends MaybeSource<? extends T>> sources) MaybeDefer
(Supplier<? extends MaybeSource<? extends T>> maybeSupplier) MaybeFlatMapBiSelector
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) 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) 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) MaybeFlatten
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper) MaybeOnErrorNext
(MaybeSource<T> source, Function<? super Throwable, ? extends MaybeSource<? extends T>> resumeFunction) MaybeUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends MaybeSource<? extends T>> sourceSupplier, Consumer<? super D> resourceDisposer, boolean eager) MaybeZipIterable
(Iterable<? extends MaybeSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper) (package private)
OnErrorNextMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends MaybeSource<? extends T>> resumeFunction) -
Uses of MaybeSource in io.reactivex.rxjava3.internal.operators.mixed
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as MaybeSourceModifier and TypeFieldDescription(package private) final MaybeSource
<T> MaybeFlatMapObservable.source
(package private) final MaybeSource
<T> MaybeFlatMapPublisher.source
Fields in io.reactivex.rxjava3.internal.operators.mixed with type parameters of type MaybeSourceModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableConcatMapMaybe.ConcatMapMaybeSubscriber.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableConcatMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableConcatMapMaybePublisher.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableSwitchMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableSwitchMapMaybePublisher.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableConcatMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableSwitchMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.mapper
Method parameters in io.reactivex.rxjava3.internal.operators.mixed with type arguments of type MaybeSourceModifier and TypeMethodDescription(package private) static <T,
R> boolean ScalarXMapZHelper.tryAsMaybe
(Object source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, Observer<? super R> observer) Try subscribing to aMaybeSource
mapped from a scalar source (which implementsSupplier
).Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type MaybeSourceModifierConstructorDescriptionMaybeFlatMapObservable
(MaybeSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> mapper) MaybeFlatMapPublisher
(MaybeSource<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) Constructor parameters in io.reactivex.rxjava3.internal.operators.mixed with type arguments of type MaybeSourceModifierConstructorDescription(package private)
ConcatMapMaybeMainObserver
(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) (package private)
ConcatMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) FlowableConcatMapMaybe
(Flowable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) FlowableConcatMapMaybePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) FlowableSwitchMapMaybe
(Flowable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) FlowableSwitchMapMaybePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) ObservableConcatMapMaybe
(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) ObservableSwitchMapMaybe
(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) (package private)
SwitchMapMaybeMainObserver
(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) (package private)
SwitchMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) -
Uses of MaybeSource in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement MaybeSourceModifier and TypeClassDescriptionfinal class
final class
Consumes the source ObservableSource and emits its last item, the defaultItem if empty or a NoSuchElementException if even the defaultItem is null.final class
Reduce a sequence of values into a single value via an aggregator function and emit the final value or complete if the source is empty.final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as MaybeSourceModifier and TypeFieldDescription(package private) MaybeSource
<? extends T> ObservableConcatWithMaybe.ConcatWithObserver.other
(package private) final MaybeSource
<? extends T> ObservableConcatWithMaybe.other
(package private) final MaybeSource
<? extends T> ObservableMergeWithMaybe.other
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type MaybeSourceModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableFlatMapMaybe.FlatMapMaybeObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableFlatMapMaybe.mapper
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type MaybeSourceModifierConstructorDescription(package private)
ConcatWithObserver
(Observer<? super T> actual, MaybeSource<? extends T> other) ObservableConcatWithMaybe
(Observable<T> source, MaybeSource<? extends T> other) ObservableMergeWithMaybe
(Observable<T> source, MaybeSource<? extends T> other) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type MaybeSourceModifierConstructorDescription(package private)
FlatMapMaybeObserver
(Observer<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) ObservableFlatMapMaybe
(ObservableSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayError) -
Uses of MaybeSource in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement MaybeSourceModifier and TypeClassDescriptionfinal class
SingleDematerialize<T,
R> Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.final class
SingleFlatMapMaybe<T,
R> final class
Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.Fields in io.reactivex.rxjava3.internal.operators.single with type parameters of type MaybeSourceModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> SingleFlatMapMaybe.FlatMapSingleObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> SingleFlatMapMaybe.mapper
Constructor parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type MaybeSourceModifierConstructorDescription(package private)
FlatMapSingleObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper) SingleFlatMapMaybe
(SingleSource<? extends T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper) -
Uses of MaybeSource in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement MaybeSourceModifier and TypeClassDescriptionfinal class
MaybeSubject<T>
Represents a hot Maybe-like source and consumer of events similar to Subjects.