- accept(T1, T2) - Method in interface io.reactivex.rxjava3.functions.BiConsumer
-
Performs an operation on the given values.
- accept(T) - Method in interface io.reactivex.rxjava3.functions.Consumer
-
Consume the given value.
- accept(long) - Method in interface io.reactivex.rxjava3.functions.LongConsumer
-
Consume a primitive long input.
- Action - Interface in io.reactivex.rxjava3.functions
-
A functional interface similar to Runnable but allows throwing a checked exception.
- add(Disposable) - Method in class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Adds a
Disposable
to this container or disposes it if the
container has been disposed.
- add(Disposable) - Method in interface io.reactivex.rxjava3.disposables.DisposableContainer
-
Adds a disposable to this container or disposes it if the
container has been disposed.
- add(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceCompletableObserver
-
Adds a resource to this ResourceCompletableObserver
.
- add(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceMaybeObserver
-
Adds a resource to this ResourceMaybeObserver
.
- add(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceObserver
-
Adds a resource to this ResourceObserver
.
- add(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceSingleObserver
-
Adds a resource to this ResourceSingleObserver
.
- add(Disposable) - Method in class io.reactivex.rxjava3.subscribers.ResourceSubscriber
-
Adds a resource to this ResourceSubscriber
.
- addAll(Disposable...) - Method in class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Atomically adds the given array of
Disposable
s to the container or
disposes them all if the container has been disposed.
- advanceTimeBy(long, TimeUnit) - Method in class io.reactivex.rxjava3.schedulers.TestScheduler
-
Moves the Scheduler's clock forward by a specified amount of time.
- advanceTimeTo(long, TimeUnit) - Method in class io.reactivex.rxjava3.schedulers.TestScheduler
-
Moves the Scheduler's clock to a particular moment in time.
- all(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that emits a
Boolean
that indicates whether all of the items emitted by the current
Flowable
satisfy a condition.
- all(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that emits a
Boolean
that indicates whether all of the items emitted by the current
Observable
satisfy a condition.
- amb(Iterable<? extends CompletableSource>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which terminates as soon as one of the source
Completable
s in the
Iterable
sequence
terminates (normally or with an error) and disposes all other
Completable
s.
- amb(Iterable<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Mirrors the one
Publisher
in an
Iterable
of several
Publisher
s that first either emits an item or sends
a termination notification.
- amb(Iterable<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Runs multiple
MaybeSource
s provided by an
Iterable
sequence and
signals the events of the first one that signals (disposing the rest).
- amb(Iterable<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Mirrors the one
ObservableSource
in an
Iterable
of several
ObservableSource
s that first either emits an item or sends
a termination notification.
- amb(Iterable<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Runs multiple
SingleSource
s and signals the events of the first one that signals (disposing
the rest).
- ambArray(CompletableSource...) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which terminates as soon as one of the source Completable
s
terminates (normally or with an error) and disposes all other Completable
s.
- ambArray(Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Mirrors the one
Publisher
in an array of several
Publisher
s that first either emits an item or sends
a termination notification.
- ambArray(MaybeSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Runs multiple
MaybeSource
s and signals the events of the first one that signals (disposing
the rest).
- ambArray(ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
Mirrors the one
ObservableSource
in an array of several
ObservableSource
s that first either emits an item or sends
a termination notification.
- ambArray(SingleSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Single
-
Runs multiple
SingleSource
s and signals the events of the first one that signals (disposing
the rest).
- ambWith(CompletableSource) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
that emits the a terminated event of either this
Completable
or the other
CompletableSource
, whichever fires first.
- ambWith(Publisher<? extends T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Mirrors the
Publisher
(current or provided) that first either emits an item or sends a termination
notification.
- ambWith(MaybeSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Mirrors the
MaybeSource
(current or provided) that first signals an event.
- ambWith(ObservableSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Mirrors the current
Observable
or the other
ObservableSource
provided of which the first either emits an item or sends a termination
notification.
- ambWith(SingleSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Single
-
Signals the event of this or the other
SingleSource
whichever signals first.
- andThen(ObservableSource<T>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns an
Observable
which will subscribe to this
Completable
and once that is completed then
will subscribe to the
next
ObservableSource
.
- andThen(Publisher<T>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Flowable
which will subscribe to this
Completable
and once that is completed then
will subscribe to the
next
Publisher
.
- andThen(SingleSource<T>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Single
which will subscribe to this
Completable
and once that is completed then
will subscribe to the
next
SingleSource
.
- andThen(MaybeSource<T>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Maybe
which will subscribe to this
Completable
and once that is completed then
will subscribe to the
next
MaybeSource
.
- andThen(CompletableSource) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
that first runs this
Completable
and then the other
CompletableSource
.
- any(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that emits
true
if any item emitted by the current
Flowable
satisfies a
specified condition, otherwise
false
.
- any(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that emits
true
if any item emitted by the current
Observable
satisfies a
specified condition, otherwise
false
.
- ANY - Static variable in interface io.reactivex.rxjava3.operators.QueueFuseable
-
- apply(Completable) - Method in interface io.reactivex.rxjava3.core.CompletableConverter
-
Applies a function to the upstream Completable and returns a converted value of type R
.
- apply(CompletableObserver) - Method in interface io.reactivex.rxjava3.core.CompletableOperator
-
Applies a function to the child
CompletableObserver
and returns a new parent
CompletableObserver
.
- apply(Completable) - Method in interface io.reactivex.rxjava3.core.CompletableTransformer
-
- apply(Flowable<T>) - Method in interface io.reactivex.rxjava3.core.FlowableConverter
-
Applies a function to the upstream
Flowable
and returns a converted value of type
R
.
- apply(Subscriber<? super Downstream>) - Method in interface io.reactivex.rxjava3.core.FlowableOperator
-
Applies a function to the child
Subscriber
and returns a new parent
Subscriber
.
- apply(Flowable<Upstream>) - Method in interface io.reactivex.rxjava3.core.FlowableTransformer
-
Applies a function to the upstream
Flowable
and returns a
Publisher
with
optionally different element type.
- apply(Maybe<T>) - Method in interface io.reactivex.rxjava3.core.MaybeConverter
-
Applies a function to the upstream
Maybe
and returns a converted value of type
R
.
- apply(MaybeObserver<? super Downstream>) - Method in interface io.reactivex.rxjava3.core.MaybeOperator
-
Applies a function to the child
MaybeObserver
and returns a new parent
MaybeObserver
.
- apply(Maybe<Upstream>) - Method in interface io.reactivex.rxjava3.core.MaybeTransformer
-
Applies a function to the upstream
Maybe
and returns a
MaybeSource
with
optionally different element type.
- apply(Observable<T>) - Method in interface io.reactivex.rxjava3.core.ObservableConverter
-
Applies a function to the upstream
Observable
and returns a converted value of type
R
.
- apply(Observer<? super Downstream>) - Method in interface io.reactivex.rxjava3.core.ObservableOperator
-
Applies a function to the child
Observer
and returns a new parent
Observer
.
- apply(Observable<Upstream>) - Method in interface io.reactivex.rxjava3.core.ObservableTransformer
-
- apply(Single<T>) - Method in interface io.reactivex.rxjava3.core.SingleConverter
-
Applies a function to the upstream
Single
and returns a converted value of type
R
.
- apply(SingleObserver<? super Downstream>) - Method in interface io.reactivex.rxjava3.core.SingleOperator
-
Applies a function to the child
SingleObserver
and returns a new parent
SingleObserver
.
- apply(Single<Upstream>) - Method in interface io.reactivex.rxjava3.core.SingleTransformer
-
Applies a function to the upstream
Single
and returns a
SingleSource
with
optionally different element type.
- apply(T1, T2) - Method in interface io.reactivex.rxjava3.functions.BiFunction
-
Calculate a value based on the input values.
- apply(T) - Method in interface io.reactivex.rxjava3.functions.Function
-
Apply some calculation to the input value and return some other value.
- apply(T1, T2, T3) - Method in interface io.reactivex.rxjava3.functions.Function3
-
Calculate a value based on the input values.
- apply(T1, T2, T3, T4) - Method in interface io.reactivex.rxjava3.functions.Function4
-
Calculate a value based on the input values.
- apply(T1, T2, T3, T4, T5) - Method in interface io.reactivex.rxjava3.functions.Function5
-
Calculate a value based on the input values.
- apply(T1, T2, T3, T4, T5, T6) - Method in interface io.reactivex.rxjava3.functions.Function6
-
Calculate a value based on the input values.
- apply(T1, T2, T3, T4, T5, T6, T7) - Method in interface io.reactivex.rxjava3.functions.Function7
-
Calculate a value based on the input values.
- apply(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface io.reactivex.rxjava3.functions.Function8
-
Calculate a value based on the input values.
- apply(T1, T2, T3, T4, T5, T6, T7, T8, T9) - Method in interface io.reactivex.rxjava3.functions.Function9
-
Calculate a value based on the input values.
- apply(int) - Method in interface io.reactivex.rxjava3.functions.IntFunction
-
Calculates a value based on a primitive integer input.
- apply(Long, Throwable) - Method in enum io.reactivex.rxjava3.parallel.ParallelFailureHandling
-
- apply(ParallelFlowable<T>) - Method in interface io.reactivex.rxjava3.parallel.ParallelFlowableConverter
-
Applies a function to the upstream ParallelFlowable and returns a converted value of type R
.
- apply(ParallelFlowable<Upstream>) - Method in interface io.reactivex.rxjava3.parallel.ParallelTransformer
-
Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with
optionally different element type.
- assertComplete() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this TestObserver
/TestSubscriber
received exactly one onComplete
event.
- assertEmpty() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the
TestObserver
/
TestSubscriber
has received a
Disposable
/
Subscription
via
onSubscribe
but no other events.
- assertError(Throwable) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this TestObserver
/TestSubscriber
received exactly the specified onError
event value.
- assertError(Class<? extends Throwable>) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Asserts that this
TestObserver
/
TestSubscriber
received exactly one
onError
event which is an
instance of the specified
errorClass
Class
.
- assertError(Predicate<Throwable>) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Asserts that this TestObserver
/TestSubscriber
received exactly one onError
event for which
the provided predicate returns true
.
- assertFailure(Class<? extends Throwable>, T...) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the upstream signaled the specified values in order
and then failed with a specific class or subclass of
Throwable
.
- assertNoErrors() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this TestObserver
/TestSubscriber
has not received an onError
event.
- assertNotComplete() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this TestObserver
/TestSubscriber
has not received an onComplete
event.
- assertNoValues() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this TestObserver
/TestSubscriber
has not received any onNext
events.
- assertResult(T...) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the upstream signaled the specified values in order and
completed normally.
- assertSubscribed() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the onSubscribe
method was called exactly once.
- assertSubscribed() - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- assertSubscribed() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- assertValue(T) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this
TestObserver
/
TestSubscriber
received exactly one
onNext
value which is equal to
the given value with respect to
Objects.equals(Object, Object)
.
- assertValue(Predicate<T>) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Asserts that this TestObserver
/TestSubscriber
received exactly one onNext
value for which
the provided predicate returns true
.
- assertValueAt(int, T) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Asserts that this
TestObserver
/
TestSubscriber
received an
onNext
value at the given index
which is equal to the given value with respect to
null
-safe
Objects.equals(Object, Object)
.
- assertValueAt(int, Predicate<T>) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Asserts that this TestObserver
/TestSubscriber
received an onNext
value at the given index
for the provided predicate returns true
.
- assertValueCount(int) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that this TestObserver
/TestSubscriber
received the specified number onNext
events.
- assertValues(T...) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the TestObserver
/TestSubscriber
received only the specified values in the specified order.
- assertValueSequence(Iterable<? extends T>) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the TestObserver
/TestSubscriber
received only the specified sequence of values in the same order.
- assertValuesOnly(T...) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Assert that the TestObserver
/TestSubscriber
received only the specified values in the specified order without terminating.
- ASYNC - Static variable in interface io.reactivex.rxjava3.operators.QueueFuseable
-
- AsyncProcessor<T> - Class in io.reactivex.rxjava3.processors
-
Processor that emits the very last value followed by a completion event or the received error
to
Subscriber
s.
- AsyncSubject<T> - Class in io.reactivex.rxjava3.subjects
-
A Subject that emits the very last value followed by a completion event or the received error to Observers.
- autoConnect() - Method in class io.reactivex.rxjava3.flowables.ConnectableFlowable
-
Returns a
Flowable
that automatically connects (at most once) to this
ConnectableFlowable
when the first
Subscriber
subscribes.
- autoConnect(int) - Method in class io.reactivex.rxjava3.flowables.ConnectableFlowable
-
Returns a
Flowable
that automatically connects (at most once) to this
ConnectableFlowable
when the specified number of
Subscriber
s subscribe to it.
- autoConnect(int, Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.flowables.ConnectableFlowable
-
Returns a
Flowable
that automatically connects (at most once) to this
ConnectableFlowable
when the specified number of
Subscriber
s subscribe to it and calls the
specified callback with the
Disposable
associated with the established connection.
- autoConnect() - Method in class io.reactivex.rxjava3.observables.ConnectableObservable
-
Returns an
Observable
that automatically connects (at most once) to this
ConnectableObservable
when the first
Observer
subscribes.
- autoConnect(int) - Method in class io.reactivex.rxjava3.observables.ConnectableObservable
-
Returns an
Observable
that automatically connects (at most once) to this
ConnectableObservable
when the specified number of
Observer
s subscribe to it.
- autoConnect(int, Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.observables.ConnectableObservable
-
Returns an
Observable
that automatically connects (at most once) to this
ConnectableObservable
when the specified number of
Observer
s subscribe to it and calls the
specified callback with the
Disposable
associated with the established connection.
- await() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Awaits until this TestObserver
/TestSubscriber
receives an onError
or onComplete
events.
- await(long, TimeUnit) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Awaits the specified amount of time or until this TestObserver
/TestSubscriber
receives an onError
or onComplete
events, whichever happens first.
- awaitCount(int) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Await until the TestObserver
/TestSubscriber
receives the given
number of items or terminates by sleeping 10 milliseconds at a time
up to 5000 milliseconds of timeout.
- awaitDone(long, TimeUnit) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Awaits until the internal latch is counted down.
- BackpressureKind - Enum in io.reactivex.rxjava3.annotations
-
Enumeration for various kinds of backpressure support.
- BackpressureOverflowStrategy - Enum in io.reactivex.rxjava3.core
-
Options to deal with buffer overflow when using onBackpressureBuffer.
- BackpressureStrategy - Enum in io.reactivex.rxjava3.core
-
Represents the options for applying backpressure to a source sequence.
- BackpressureSupport - Annotation Type in io.reactivex.rxjava3.annotations
-
Indicates the backpressure support kind of the associated operator or class.
- BaseTestConsumer<T,U extends BaseTestConsumer<T,U>> - Class in io.reactivex.rxjava3.observers
-
- BaseTestConsumer() - Constructor for class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Constructs a BaseTestConsumer
with CountDownLatch
set to 1.
- BehaviorProcessor<T> - Class in io.reactivex.rxjava3.processors
-
Processor that emits the most recent item it has observed and all subsequent observed items to each subscribed
Subscriber
.
- BehaviorSubject<T> - Class in io.reactivex.rxjava3.subjects
-
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer
.
- Beta - Annotation Type in io.reactivex.rxjava3.annotations
-
Indicates the feature is in beta state: it will be most likely stay but
the signature may change between versions without warning.
- BiConsumer<T1,T2> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that accepts two values (of possibly different types).
- BiFunction<T1,T2,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- BiPredicate<T1,T2> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that returns true or false for the given input values.
- blockingAwait() - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to and awaits the termination of this Completable
instance in a blocking manner and
rethrows any exception emitted.
- blockingAwait(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to and awaits the termination of this Completable
instance in a blocking manner
with a specific timeout and rethrows any exception emitted within the timeout window.
- blockingFirst() - Method in class io.reactivex.rxjava3.core.Flowable
-
- blockingFirst(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns the first item emitted by this Flowable
, or a default value if it emits no
items.
- blockingFirst() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns the first item emitted by the current
Observable
, or throws
NoSuchElementException
if it emits no items.
- blockingFirst(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns the first item emitted by the current Observable
, or a default value if it emits no
items.
- blockingForEach(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Consumes the current
Flowable
in a blocking fashion and invokes the given
Consumer
with each upstream item on the
current thread until the
upstream terminates.
- blockingForEach(Consumer<? super T>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Consumes the current
Flowable
in a blocking fashion and invokes the given
Consumer
with each upstream item on the
current thread until the
upstream terminates.
- blockingForEach(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Consumes the current
Observable
in a blocking fashion and invokes the given
Consumer
with each upstream item on the
current thread until the
upstream terminates.
- blockingForEach(Consumer<? super T>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Consumes the current
Observable
in a blocking fashion and invokes the given
Consumer
with each upstream item on the
current thread until the
upstream terminates.
- blockingGet() - Method in class io.reactivex.rxjava3.core.Maybe
-
Waits in a blocking fashion until the current Maybe
signals a success value (which is returned),
null
if completed or an exception (which is propagated).
- blockingGet(T) - Method in class io.reactivex.rxjava3.core.Maybe
-
Waits in a blocking fashion until the current Maybe
signals a success value (which is returned),
defaultValue if completed or an exception (which is propagated).
- blockingGet() - Method in class io.reactivex.rxjava3.core.Single
-
Waits in a blocking fashion until the current Single
signals a success value (which is returned) or
an exception (which is propagated).
- blockingIterable() - Method in class io.reactivex.rxjava3.core.Flowable
-
Converts this
Flowable
into an
Iterable
.
- blockingIterable(int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Converts this
Flowable
into an
Iterable
.
- blockingIterable() - Method in class io.reactivex.rxjava3.core.Observable
-
Exposes the current
Observable
as an
Iterable
which, when iterated,
subscribes to the current
Observable
and blocks
until the current
Observable
emits items or terminates.
- blockingIterable(int) - Method in class io.reactivex.rxjava3.core.Observable
-
Exposes the current
Observable
as an
Iterable
which, when iterated,
subscribes to the current
Observable
and blocks
until the current
Observable
emits items or terminates.
- blockingLast() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns the last item emitted by this
Flowable
, or throws
NoSuchElementException
if this
Flowable
emits no items.
- blockingLast(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns the last item emitted by this Flowable
, or a default value if it emits no
items.
- blockingLast() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns the last item emitted by the current
Observable
, or throws
NoSuchElementException
if the current
Observable
emits no items.
- blockingLast(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns the last item emitted by the current Observable
, or a default value if it emits no
items.
- blockingLatest() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns an
Iterable
that returns the latest item emitted by this
Flowable
,
waiting if necessary for one to become available.
- blockingLatest() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Iterable
that returns the latest item emitted by the current
Observable
,
waiting if necessary for one to become available.
- blockingMostRecent(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns an
Iterable
that always returns the item most recently emitted by this
Flowable
.
- blockingMostRecent(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Iterable
that always returns the item most recently emitted by the current
Observable
.
- blockingNext() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns an
Iterable
that blocks until this
Flowable
emits another item, then
returns that item.
- blockingNext() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Iterable
that blocks until the current
Observable
emits another item, then
returns that item.
- blockingSingle() - Method in class io.reactivex.rxjava3.core.Flowable
-
If this
Flowable
completes after emitting a single item, return that item, otherwise
throw a
NoSuchElementException
.
- blockingSingle(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
If this
Flowable
completes after emitting a single item, return that item; if it emits
more than one item, throw an
IllegalArgumentException
; if it emits no items, return a default
value.
- blockingSingle() - Method in class io.reactivex.rxjava3.core.Observable
-
If the current
Observable
completes after emitting a single item, return that item, otherwise
throw a
NoSuchElementException
.
- blockingSingle(T) - Method in class io.reactivex.rxjava3.core.Observable
-
If the current
Observable
completes after emitting a single item, return that item; if it emits
more than one item, throw an
IllegalArgumentException
; if it emits no items, return a default
value.
- blockingStream() - Method in class io.reactivex.rxjava3.core.Flowable
-
Creates a sequential
Stream
to consume or process this
Flowable
in a blocking manner via
the Java
Stream
API.
- blockingStream(int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Creates a sequential
Stream
to consume or process this
Flowable
in a blocking manner via
the Java
Stream
API.
- blockingStream() - Method in class io.reactivex.rxjava3.core.Observable
-
Creates a sequential
Stream
to consume or process the current
Observable
in a blocking manner via
the Java
Stream
API.
- blockingStream(int) - Method in class io.reactivex.rxjava3.core.Observable
-
Creates a sequential
Stream
to consume or process the current
Observable
in a blocking manner via
the Java
Stream
API.
- blockingSubscribe() - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to the current Completable
and blocks the current thread until it terminates.
- blockingSubscribe(Action) - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to the current Completable
and calls given onComplete
callback on the current thread
when it completes normally.
- blockingSubscribe(Action, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to the current Completable
and calls the appropriate callback on the current thread
when it terminates.
- blockingSubscribe(CompletableObserver) - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to the current
Completable
and calls the appropriate
CompletableObserver
method on the
current thread.
- blockingSubscribe() - Method in class io.reactivex.rxjava3.core.Flowable
-
Runs the current Flowable
to a terminal event, ignoring any values and rethrowing any exception.
- blockingSubscribe(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, Action, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Subscriber<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the source and calls the
Subscriber
methods
on the current thread.
- blockingSubscribe() - Method in class io.reactivex.rxjava3.core.Maybe
-
Subscribes to the current Maybe
and blocks the current thread until it terminates.
- blockingSubscribe(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Subscribes to the current Maybe
and calls given onSuccess
callback on the current thread
when it completes normally.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Subscribes to the current Maybe
and calls the appropriate callback on the current thread
when it terminates.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
Subscribes to the current Maybe
and calls the appropriate callback on the current thread
when it terminates.
- blockingSubscribe(MaybeObserver<? super T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Subscribes to the current
Maybe
and calls the appropriate
MaybeObserver
method on the
current thread.
- blockingSubscribe() - Method in class io.reactivex.rxjava3.core.Observable
-
Runs the current Observable
to a terminal event, ignoring any values and rethrowing any exception.
- blockingSubscribe(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>, Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the source and calls the given callbacks on the current thread.
- blockingSubscribe(Observer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the source and calls the
Observer
methods
on the current thread.
- blockingSubscribe() - Method in class io.reactivex.rxjava3.core.Single
-
Subscribes to the current Single
and blocks the current thread until it terminates.
- blockingSubscribe(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Single
-
Subscribes to the current Single
and calls given onSuccess
callback on the current thread
when it completes normally.
- blockingSubscribe(Consumer<? super T>, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Single
-
Subscribes to the current Single
and calls the appropriate callback on the current thread
when it terminates.
- blockingSubscribe(SingleObserver<? super T>) - Method in class io.reactivex.rxjava3.core.Single
-
Subscribes to the current
Single
and calls the appropriate
SingleObserver
method on the
current thread.
- BooleanSupplier - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that returns a boolean value.
- BOUNDARY - Static variable in interface io.reactivex.rxjava3.operators.QueueFuseable
-
- buffer(int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(int, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(int, int, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(int, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, long, TimeUnit, Scheduler, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, TimeUnit, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, TimeUnit, Scheduler, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, TimeUnit, Scheduler, int, Supplier<U>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(Publisher<? extends TOpening>, Function<? super TOpening, ? extends Publisher<? extends TClosing>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(Publisher<? extends TOpening>, Function<? super TOpening, ? extends Publisher<? extends TClosing>>, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits buffers of items it collects from the current Flowable
.
- buffer(Publisher<B>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits non-overlapping buffered items from the current
Flowable
each time the
specified boundary
Publisher
emits an item.
- buffer(Publisher<B>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits non-overlapping buffered items from the current
Flowable
each time the
specified boundary
Publisher
emits an item.
- buffer(Publisher<B>, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits non-overlapping buffered items from the current
Flowable
each time the
specified boundary
Publisher
emits an item.
- buffer(int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(int, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(int, int, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(int, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, long, TimeUnit, Scheduler, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, TimeUnit, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, TimeUnit, Scheduler, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, TimeUnit, Scheduler, int, Supplier<U>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(ObservableSource<? extends TOpening>, Function<? super TOpening, ? extends ObservableSource<? extends TClosing>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(ObservableSource<? extends TOpening>, Function<? super TOpening, ? extends ObservableSource<? extends TClosing>>, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits buffers of items it collects from the current Observable
.
- buffer(ObservableSource<B>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits non-overlapping buffered items from the current
Observable
each time the
specified boundary
ObservableSource
emits an item.
- buffer(ObservableSource<B>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits non-overlapping buffered items from the current
Observable
each time the
specified boundary
ObservableSource
emits an item.
- buffer(ObservableSource<B>, Supplier<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits non-overlapping buffered items from the current
Observable
each time the
specified boundary
ObservableSource
emits an item.
- bufferSize() - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns the default internal buffer size used by most async operators.
- bufferSize() - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns the default 'island' size or capacity-increment hint for unbounded buffers.
- cache() - Method in class io.reactivex.rxjava3.core.Completable
-
Subscribes to this
Completable
only once, when the first
CompletableObserver
subscribes to the result
Completable
, caches its terminal event
and relays/replays it to observers.
- cache() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that subscribes to this
Publisher
lazily, caches all of its events
and replays them, in the same order as received, to all the downstream subscribers.
- cache() - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
that subscribes to this Maybe
lazily, caches its event
and replays it, to all the downstream subscribers.
- cache() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that subscribes to the current Observable
lazily, caches all of its events
and replays them, in the same order as received, to all the downstream observers.
- cache() - Method in class io.reactivex.rxjava3.core.Single
-
Stores the success value or exception from the current
Single
and replays it to late
SingleObserver
s.
- cacheWithInitialCapacity(int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that subscribes to this
Publisher
lazily, caches all of its events
and replays them, in the same order as received, to all the downstream subscribers.
- cacheWithInitialCapacity(int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that subscribes to the current Observable
lazily, caches all of its events
and replays them, in the same order as received, to all the downstream observers.
- cancel() - Method in interface io.reactivex.rxjava3.functions.Cancellable
-
Cancel the action or free a resource.
- cancel() - Method in class io.reactivex.rxjava3.observers.DefaultObserver
-
Cancels the upstream's disposable.
- cancel() - Method in class io.reactivex.rxjava3.subscribers.DefaultSubscriber
-
- cancel() - Method in class io.reactivex.rxjava3.subscribers.DisposableSubscriber
-
- cancel() - Method in class io.reactivex.rxjava3.subscribers.SafeSubscriber
-
- cancel() - Method in class io.reactivex.rxjava3.subscribers.SerializedSubscriber
-
- cancel() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- Cancellable - Interface in io.reactivex.rxjava3.functions
-
A functional interface that has a single cancel method
that can throw.
- cast(Class<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the upstream items while
they can be cast via
Class.cast(Object)
until the upstream terminates,
or until the upstream signals an item which can't be cast,
resulting in a
ClassCastException
to be signaled to the downstream.
- cast(Class<? extends U>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Casts the success value of the current
Maybe
into the target type or signals a
ClassCastException
if not compatible.
- cast(Class<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the upstream items while
they can be cast via
Class.cast(Object)
until the upstream terminates,
or until the upstream signals an item which can't be cast,
resulting in a
ClassCastException
to be signaled to the downstream.
- cast(Class<? extends U>) - Method in class io.reactivex.rxjava3.core.Single
-
Casts the success value of the current
Single
into the target type or signals a
ClassCastException
if not compatible.
- CheckReturnValue - Annotation Type in io.reactivex.rxjava3.annotations
-
Marks methods whose return values should be checked.
- checkSubscriptionOnce - Variable in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
- cleanupBuffer() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Makes sure the item cached by the head node in a bounded
ReplayProcessor is released (as it is never part of a replay).
- cleanupBuffer() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Makes sure the item cached by the head node in a bounded
ReplaySubject is released (as it is never part of a replay).
- clear() - Method in class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Atomically clears the container, then disposes all the previously contained
Disposable
s.
- clear() - Method in interface io.reactivex.rxjava3.operators.SimpleQueue
-
Removes all enqueued items from this queue.
- clear() - Method in class io.reactivex.rxjava3.operators.SpscArrayQueue
-
- clear() - Method in class io.reactivex.rxjava3.operators.SpscLinkedArrayQueue
-
- clockDriftTolerance() - Static method in class io.reactivex.rxjava3.core.Scheduler
-
Returns the clock drift tolerance in nanoseconds.
- collect(Supplier<? extends U>, BiConsumer<? super U, ? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Collects items emitted by the finite source
Publisher
into a single mutable data structure and returns
a
Single
that emits this structure.
- collect(Collector<? super T, A, R>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Collects the finite upstream's values into a container via a
Stream
Collector
callback set and emits
it as the success result.
- collect(Supplier<? extends U>, BiConsumer<? super U, ? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Collects items emitted by the finite source
Observable
into a single mutable data structure and returns
a
Single
that emits this structure.
- collect(Collector<? super T, A, R>) - Method in class io.reactivex.rxjava3.core.Observable
-
Collects the finite upstream's values into a container via a
Stream
Collector
callback set and emits
it as the success result as a
Single
.
- collect(Supplier<? extends C>, BiConsumer<? super C, ? super T>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Collect the elements in each rail into a collection supplied via a collectionSupplier
and collected into with a collector action, emitting the collection at the end.
- collect(Collector<T, A, R>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Reduces all values within a 'rail' and across 'rails' with a callbacks
of the given
Collector
into one
Flowable
containing a single value.
- collectInto(U, BiConsumer<? super U, ? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Collects items emitted by the finite source
Publisher
into a single mutable data structure and returns
a
Single
that emits this structure.
- collectInto(U, BiConsumer<? super U, ? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Collects items emitted by the finite source
Observable
into a single mutable data structure and returns
a
Single
that emits this structure.
- combineLatest(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines two source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from either of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Function3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines three source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines four source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines five source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines six source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines seven source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Publisher<? extends T8>, Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines eight source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Publisher<? extends T1>, Publisher<? extends T2>, Publisher<? extends T3>, Publisher<? extends T4>, Publisher<? extends T5>, Publisher<? extends T6>, Publisher<? extends T7>, Publisher<? extends T8>, Publisher<? extends T9>, Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines nine source
Publisher
s by emitting an item that aggregates the latest values of each of the
source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatest(Iterable<? extends ObservableSource<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines a collection of source
ObservableSource
s by emitting an item that aggregates the latest values of each of
the returned
ObservableSource
s each time an item is received from any of the returned
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(Iterable<? extends ObservableSource<? extends T>>, Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an
Iterable
of source
ObservableSource
s by emitting an item that aggregates the latest values of each of
the returned
ObservableSource
s each time an item is received from any of the returned
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, BiFunction<? super T1, ? super T2, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines two source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from either of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, Function3<? super T1, ? super T2, ? super T3, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines three source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, ObservableSource<? extends T4>, Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines four source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, ObservableSource<? extends T4>, ObservableSource<? extends T5>, Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines five source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, ObservableSource<? extends T4>, ObservableSource<? extends T5>, ObservableSource<? extends T6>, Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines six source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, ObservableSource<? extends T4>, ObservableSource<? extends T5>, ObservableSource<? extends T6>, ObservableSource<? extends T7>, Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines seven source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, ObservableSource<? extends T4>, ObservableSource<? extends T5>, ObservableSource<? extends T6>, ObservableSource<? extends T7>, ObservableSource<? extends T8>, Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines eight source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatest(ObservableSource<? extends T1>, ObservableSource<? extends T2>, ObservableSource<? extends T3>, ObservableSource<? extends T4>, ObservableSource<? extends T5>, ObservableSource<? extends T6>, ObservableSource<? extends T7>, ObservableSource<? extends T8>, ObservableSource<? extends T9>, Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines nine source
ObservableSource
s by emitting an item that aggregates the latest values of each of the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatestArray(Publisher<? extends T>[], Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatestArray(Publisher<? extends T>[], Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatestArray(ObservableSource<? extends T>[], Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an array of source
ObservableSource
s by emitting an item that aggregates the latest values of each of
the
ObservableSource
s each time an item is received from any of the returned
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatestArray(ObservableSource<? extends T>[], Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an array of source
ObservableSource
s by emitting an item that aggregates the latest values of each of
the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatestArrayDelayError(Publisher<? extends T>[], Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function.
- combineLatestArrayDelayError(Publisher<? extends T>[], Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source
Publisher
s terminate.
- combineLatestArrayDelayError(ObservableSource<? extends T>[], Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an array of
ObservableSource
s by emitting an item that aggregates the latest values of each of
the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function.
- combineLatestArrayDelayError(ObservableSource<? extends T>[], Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an array of
ObservableSource
s by emitting an item that aggregates the latest values of each of
the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source
ObservableSource
s terminate.
- combineLatestDelayError(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source
Publisher
s terminate.
- combineLatestDelayError(Iterable<? extends Publisher<? extends T>>, Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Combines a collection of source
Publisher
s by emitting an item that aggregates the latest values of each of
the source
Publisher
s each time an item is received from any of the source
Publisher
s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source
Publisher
s terminate.
- combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>>, Function<? super Object[], ? extends R>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an
Iterable
of
ObservableSource
s by emitting an item that aggregates the latest values of each of
the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source
ObservableSource
s terminate.
- combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>>, Function<? super Object[], ? extends R>, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Combines an
Iterable
of
ObservableSource
s by emitting an item that aggregates the latest values of each of
the
ObservableSource
s each time an item is received from any of the
ObservableSource
s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source
ObservableSource
s terminate.
- Completable - Class in io.reactivex.rxjava3.core
-
The Completable
class represents a deferred computation without any value but
only indication for completion or exception.
- Completable() - Constructor for class io.reactivex.rxjava3.core.Completable
-
- CompletableConverter<R> - Interface in io.reactivex.rxjava3.core
-
- CompletableEmitter - Interface in io.reactivex.rxjava3.core
-
- CompletableObserver - Interface in io.reactivex.rxjava3.core
-
Provides a mechanism for receiving push-based notification of a valueless completion or an error.
- CompletableOnSubscribe - Interface in io.reactivex.rxjava3.core
-
A functional interface that has a
subscribe()
method that receives
a
CompletableEmitter
instance that allows pushing
an event in a cancellation-safe manner.
- CompletableOperator - Interface in io.reactivex.rxjava3.core
-
Interface to map/wrap a downstream observer to an upstream observer.
- CompletableSource - Interface in io.reactivex.rxjava3.core
-
- CompletableSubject - Class in io.reactivex.rxjava3.subjects
-
Represents a hot Completable-like source and consumer of events similar to Subjects.
- CompletableTransformer - Interface in io.reactivex.rxjava3.core
-
Convenience interface and callback used by the compose operator to turn a
Completable
into another
Completable
fluently.
- complete() - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
instance that completes immediately when subscribed to.
- completions - Variable in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
The number of completions.
- compose(CompletableTransformer) - Method in class io.reactivex.rxjava3.core.Completable
-
- compose(FlowableTransformer<? super T, ? extends R>) - Method in class io.reactivex.rxjava3.core.Flowable
-
- compose(MaybeTransformer<? super T, ? extends R>) - Method in class io.reactivex.rxjava3.core.Maybe
-
- compose(ObservableTransformer<? super T, ? extends R>) - Method in class io.reactivex.rxjava3.core.Observable
-
- compose(SingleTransformer<? super T, ? extends R>) - Method in class io.reactivex.rxjava3.core.Single
-
- compose(ParallelTransformer<T, U>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Allows composing operators, in assembly time, on top of this ParallelFlowable
and returns another ParallelFlowable
with composed features.
- CompositeDisposable - Class in io.reactivex.rxjava3.disposables
-
- CompositeDisposable() - Constructor for class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Creates an empty CompositeDisposable
.
- CompositeDisposable(Disposable...) - Constructor for class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Creates a
CompositeDisposable
with the given array of initial
Disposable
elements.
- CompositeDisposable(Iterable<? extends Disposable>) - Constructor for class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Creates a
CompositeDisposable
with the given
Iterable
sequence of initial
Disposable
elements.
- CompositeException - Exception in io.reactivex.rxjava3.exceptions
-
Represents an exception that is a composite of one or more other exceptions.
- CompositeException(Throwable...) - Constructor for exception io.reactivex.rxjava3.exceptions.CompositeException
-
Constructs a CompositeException with the given array of Throwables as the
list of suppressed exceptions.
- CompositeException(Iterable<? extends Throwable>) - Constructor for exception io.reactivex.rxjava3.exceptions.CompositeException
-
Constructs a CompositeException with the given array of Throwables as the
list of suppressed exceptions.
- COMPUTATION - Static variable in annotation type io.reactivex.rxjava3.annotations.SchedulerSupport
-
- computation() - Static method in class io.reactivex.rxjava3.schedulers.Schedulers
-
Returns a default, shared
Scheduler
instance intended for computational work.
- concat(Iterable<? extends CompletableSource>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concat(Publisher<? extends CompletableSource>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concat(Publisher<? extends CompletableSource>, int) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concat(Iterable<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates elements of each
Publisher
provided via an
Iterable
sequence into a single sequence
of elements without interleaving them.
- concat(Publisher<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items emitted by each of the
Publisher
s emitted by the source
Publisher
, one after the other, without interleaving them.
- concat(Publisher<? extends Publisher<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items emitted by each of the
Publisher
s emitted by the source
Publisher
, one after the other, without interleaving them.
- concat(Publisher<? extends T>, Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items emitted by two
Publisher
s, one after the other, without
interleaving them.
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items emitted by three
Publisher
s, one after the other, without
interleaving them.
- concat(Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>, Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items emitted by four
Publisher
s, one after the other, without
interleaving them.
- concat(Iterable<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenate the single values, in a non-overlapping fashion, of the
MaybeSource
sources provided by
an
Iterable
sequence as a
Flowable
sequence.
- concat(MaybeSource<? extends T>, MaybeSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concat(MaybeSource<? extends T>, MaybeSource<? extends T>, MaybeSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concat(MaybeSource<? extends T>, MaybeSource<? extends T>, MaybeSource<? extends T>, MaybeSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concat(Publisher<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenate the single values, in a non-overlapping fashion, of the
MaybeSource
sources provided by
a
Publisher
sequence as a
Flowable
sequence.
- concat(Publisher<? extends MaybeSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenate the single values, in a non-overlapping fashion, of the
MaybeSource
sources provided by
a
Publisher
sequence as a
Flowable
sequence.
- concat(Iterable<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates elements of each
ObservableSource
provided via an
Iterable
sequence into a single sequence
of elements without interleaving them.
- concat(ObservableSource<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items emitted by each of the
ObservableSource
s emitted by the
ObservableSource
, one after the other, without interleaving them.
- concat(ObservableSource<? extends ObservableSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items emitted by each of the
ObservableSource
s emitted by the outer
ObservableSource
, one after the other, without interleaving them.
- concat(ObservableSource<? extends T>, ObservableSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items emitted by two
ObservableSource
s, one after the other, without
interleaving them.
- concat(ObservableSource<? extends T>, ObservableSource<? extends T>, ObservableSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items emitted by three
ObservableSource
s, one after the other, without
interleaving them.
- concat(ObservableSource<? extends T>, ObservableSource<? extends T>, ObservableSource<? extends T>, ObservableSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items emitted by four
ObservableSource
s, one after the other, without
interleaving them.
- concat(Iterable<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenate the single values, in a non-overlapping fashion, of the
SingleSource
s provided by
an
Iterable
sequence.
- concat(ObservableSource<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
- concat(Publisher<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenate the single values, in a non-overlapping fashion, of the
SingleSource
s provided by
a
Publisher
sequence.
- concat(Publisher<? extends SingleSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenate the single values, in a non-overlapping fashion, of the
SingleSource
s provided by
a
Publisher
sequence and prefetched by the specified amount.
- concat(SingleSource<? extends T>, SingleSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
- concat(SingleSource<? extends T>, SingleSource<? extends T>, SingleSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
- concat(SingleSource<? extends T>, SingleSource<? extends T>, SingleSource<? extends T>, SingleSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
- concatArray(CompletableSource...) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concatArray(Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a variable number of
Publisher
sources.
- concatArray(MaybeSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenate the single values, in a non-overlapping fashion, of the
MaybeSource
sources in the array
as a
Flowable
sequence.
- concatArray(ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
- concatArray(SingleSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenate the single values, in a non-overlapping fashion, of the
SingleSource
s provided in
an array.
- concatArrayDelayError(CompletableSource...) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concatArrayDelayError(Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a variable number of
Publisher
sources and delays errors from any of them
till all terminate.
- concatArrayDelayError(MaybeSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a variable number of
MaybeSource
sources and delays errors from any of them
till all terminate as a
Flowable
sequence.
- concatArrayDelayError(ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates a variable number of
ObservableSource
sources and delays errors from any of them
till all terminate.
- concatArrayDelayError(SingleSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenate the single values, in a non-overlapping fashion, of the
SingleSource
s provided in
an array.
- concatArrayEager(Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates an array of
Publisher
s eagerly into a single stream of values.
- concatArrayEager(int, int, Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates an array of
Publisher
s eagerly into a single stream of values.
- concatArrayEager(MaybeSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concatArrayEager(ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an array of
ObservableSource
s eagerly into a single stream of values.
- concatArrayEager(int, int, ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an array of
ObservableSource
s eagerly into a single stream of values.
- concatArrayEager(SingleSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates a sequence of
SingleSource
eagerly into a single stream of values.
- concatArrayEagerDelayError(Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates an array of
Publisher
s eagerly into a single stream of values
and delaying any errors until all sources terminate.
- concatArrayEagerDelayError(int, int, Publisher<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates an array of
Publisher
s eagerly into a single stream of values
and delaying any errors until all sources terminate.
- concatArrayEagerDelayError(MaybeSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concatArrayEagerDelayError(ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an array of
ObservableSource
s eagerly into a single stream of values
and delaying any errors until all sources terminate.
- concatArrayEagerDelayError(int, int, ObservableSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an array of
ObservableSource
s eagerly into a single stream of values
and delaying any errors until all sources terminate.
- concatArrayEagerDelayError(SingleSource<? extends T>...) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates a sequence of
SingleSource
eagerly into a single stream of values.
- concatDelayError(Iterable<? extends CompletableSource>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concatDelayError(Publisher<? extends CompletableSource>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concatDelayError(Publisher<? extends CompletableSource>, int) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which completes only when all sources complete, one after another.
- concatDelayError(Iterable<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates the
Iterable
sequence of
Publisher
s into a single sequence by subscribing to each
Publisher
,
one after the other, one at a time and delays any errors till the all inner
Publisher
s terminate.
- concatDelayError(Publisher<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates the
Publisher
sequence of
Publisher
s into a single sequence by subscribing to each inner
Publisher
,
one after the other, one at a time and delays any errors till the all inner and the outer
Publisher
s terminate.
- concatDelayError(Publisher<? extends Publisher<? extends T>>, int, boolean) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates the
Publisher
sequence of
Publisher
s into a single sequence by subscribing to each inner
Publisher
,
one after the other, one at a time and delays any errors till the all inner and the outer
Publisher
s terminate.
- concatDelayError(Iterable<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates the
Iterable
sequence of
MaybeSource
s into a single sequence by subscribing to each
MaybeSource
,
one after the other, one at a time and delays any errors till the all inner
MaybeSource
s terminate
as a
Flowable
sequence.
- concatDelayError(Publisher<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates the
Publisher
sequence of
MaybeSource
s into a single sequence by subscribing to each inner
MaybeSource
,
one after the other, one at a time and delays any errors till the all inner and the outer
Publisher
terminate
as a
Flowable
sequence.
- concatDelayError(Publisher<? extends MaybeSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates the
Publisher
sequence of
MaybeSource
s into a single sequence by subscribing to each inner
MaybeSource
,
one after the other, one at a time and delays any errors till the all inner and the outer
Publisher
terminate
as a
Flowable
sequence.
- concatDelayError(Iterable<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates the
Iterable
sequence of
ObservableSource
s into a single
Observable
sequence
by subscribing to each
ObservableSource
, one after the other, one at a time and delays any errors till
the all inner
ObservableSource
s terminate.
- concatDelayError(ObservableSource<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates the
ObservableSource
sequence of
ObservableSource
s into a single
Observable
sequence
by subscribing to each inner
ObservableSource
, one after the other, one at a time and delays any errors till the
all inner and the outer
ObservableSource
s terminate.
- concatDelayError(ObservableSource<? extends ObservableSource<? extends T>>, int, boolean) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates the
ObservableSource
sequence of
ObservableSource
s into a single sequence by subscribing to each inner
ObservableSource
,
one after the other, one at a time and delays any errors till the all inner and the outer
ObservableSource
s terminate.
- concatDelayError(Iterable<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates the
Iterable
sequence of
SingleSource
s into a single sequence by subscribing to each
SingleSource
,
one after the other, one at a time and delays any errors till the all inner
SingleSource
s terminate
as a
Flowable
sequence.
- concatDelayError(Publisher<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates the
Publisher
sequence of
SingleSource
s into a single sequence by subscribing to each inner
SingleSource
,
one after the other, one at a time and delays any errors till the all inner and the outer
Publisher
terminate
as a
Flowable
sequence.
- concatDelayError(Publisher<? extends SingleSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates the
Publisher
sequence of
SingleSource
s into a single sequence by subscribing to each inner
SingleSource
,
one after the other, one at a time and delays any errors till the all inner and the outer
Publisher
terminate
as a
Flowable
sequence.
- concatEager(Iterable<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a sequence of
Publisher
s eagerly into a single stream of values.
- concatEager(Iterable<? extends Publisher<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a sequence of
Publisher
s eagerly into a single stream of values and
runs a limited number of inner sequences at once.
- concatEager(Publisher<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a
Publisher
sequence of
Publisher
s eagerly into a single stream of values.
- concatEager(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a
Publisher
sequence of
Publisher
s eagerly into a single stream of values and
runs a limited number of inner sequences at once.
- concatEager(Iterable<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concatEager(Iterable<? extends MaybeSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a sequence of
MaybeSource
s eagerly into a
Flowable
sequence and
runs a limited number of the inner sequences at once.
- concatEager(Publisher<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- concatEager(Publisher<? extends MaybeSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a
Publisher
sequence of
MaybeSource
s eagerly into a
Flowable
sequence,
running at most the given number of inner
MaybeSource
s at once.
- concatEager(Iterable<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates a sequence of
ObservableSource
s eagerly into a single stream of values.
- concatEager(Iterable<? extends ObservableSource<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates a sequence of
ObservableSource
s eagerly into a single stream of values and
runs a limited number of inner sequences at once.
- concatEager(ObservableSource<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an
ObservableSource
sequence of
ObservableSource
s eagerly into a single stream of values.
- concatEager(ObservableSource<? extends ObservableSource<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an
ObservableSource
sequence of
ObservableSource
s eagerly into a single stream of values
and runs a limited number of inner sequences at once.
- concatEager(Iterable<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
- concatEager(Iterable<? extends SingleSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates an
Iterable
sequence of
SingleSource
s eagerly into a single stream of values and
runs a limited number of the inner sources at once.
- concatEager(Publisher<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
- concatEager(Publisher<? extends SingleSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates a
Publisher
sequence of
SingleSource
s eagerly into a single stream of values and
runs a limited number of those inner
SingleSource
s at once.
- concatEagerDelayError(Iterable<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a sequence of
Publisher
s eagerly into a single stream of values,
delaying errors until all the inner sequences terminate.
- concatEagerDelayError(Iterable<? extends Publisher<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a sequence of
Publisher
s eagerly into a single stream of values,
delaying errors until all the inner sequences terminate and runs a limited number
of inner sequences at once.
- concatEagerDelayError(Publisher<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a
Publisher
sequence of
Publisher
s eagerly into a single stream of values,
delaying errors until all the inner and the outer sequences terminate.
- concatEagerDelayError(Publisher<? extends Publisher<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Concatenates a
Publisher
sequence of
Publisher
s eagerly into a single stream of values,
delaying errors until all the inner and outer sequences terminate and runs a limited number of inner
sequences at once.
- concatEagerDelayError(Iterable<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a sequence of
MaybeSource
s eagerly into a
Flowable
sequence,
delaying errors until all inner
MaybeSource
s terminate.
- concatEagerDelayError(Iterable<? extends MaybeSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a sequence of
MaybeSource
s eagerly into a
Flowable
sequence,
delaying errors until all inner
MaybeSource
s terminate and
runs a limited number of inner
MaybeSource
s at once.
- concatEagerDelayError(Publisher<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a
Publisher
sequence of
MaybeSource
s eagerly into a
Flowable
sequence,
delaying errors until all the inner and the outer sequence terminate.
- concatEagerDelayError(Publisher<? extends MaybeSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Concatenates a
Publisher
sequence of
MaybeSource
s eagerly into a
Flowable
sequence,
delaying errors until all the inner and the outer sequence terminate and
runs a limited number of the inner
MaybeSource
s at once.
- concatEagerDelayError(Iterable<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates a sequence of
ObservableSource
s eagerly into a single stream of values,
delaying errors until all the inner sequences terminate.
- concatEagerDelayError(Iterable<? extends ObservableSource<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates a sequence of
ObservableSource
s eagerly into a single stream of values,
delaying errors until all the inner sequences terminate and runs a limited number of inner
sequences at once.
- concatEagerDelayError(ObservableSource<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an
ObservableSource
sequence of
ObservableSource
s eagerly into a single stream of values,
delaying errors until all the inner and the outer sequence terminate.
- concatEagerDelayError(ObservableSource<? extends ObservableSource<? extends T>>, int, int) - Static method in class io.reactivex.rxjava3.core.Observable
-
Concatenates an
ObservableSource
sequence of
ObservableSource
s eagerly into a single stream of values,
delaying errors until all the inner and the outer sequence terminate and runs a limited number of inner sequences at once.
- concatEagerDelayError(Iterable<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates an
Iterable
sequence of
SingleSource
s eagerly into a single stream of values,
delaying errors until all the inner sources terminate.
- concatEagerDelayError(Iterable<? extends SingleSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates an
Iterable
sequence of
SingleSource
s eagerly into a single stream of values,
delaying errors until all the inner sources terminate.
- concatEagerDelayError(Publisher<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates a
Publisher
sequence of
SingleSource
s eagerly into a single stream of values,
delaying errors until all the inner and the outer sequence terminate.
- concatEagerDelayError(Publisher<? extends SingleSource<? extends T>>, int) - Static method in class io.reactivex.rxjava3.core.Single
-
Concatenates a
Publisher
sequence of
SingleSource
s eagerly into a single stream of values,
running at most the specified number of those inner
SingleSource
s at once and
delaying errors until all the inner and the outer sequence terminate.
- concatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a new
Flowable
that emits items resulting from applying a function that you supply to each item
emitted by the current
Flowable
, where that function returns a
Publisher
, and then emitting the items
that result from concatenating those returned
Publisher
s.
- concatMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a new
Flowable
that emits items resulting from applying a function that you supply to each item
emitted by the current
Flowable
, where that function returns a
Publisher
, and then emitting the items
that result from concatenating those returned
Publisher
s.
- concatMap(Function<? super T, ? extends Publisher<? extends R>>, int, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a new
Flowable
that emits items resulting from applying a function (on a designated scheduler)
that you supply to each item emitted by the current
Flowable
, where that function returns a
Publisher
, and then emitting the items
that result from concatenating those returned
Publisher
s.
- concatMap(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that is based on applying a specified function to the item emitted by the current
Maybe
,
where that function returns a
MaybeSource
.
- concatMap(Function<? super T, ? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a new
Observable
that emits items resulting from applying a function that you supply to each item
emitted by the current
Observable
, where that function returns an
ObservableSource
, and then emitting the items
that result from concatenating those returned
ObservableSource
s.
- concatMap(Function<? super T, ? extends ObservableSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a new
Observable
that emits items resulting from applying a function that you supply to each item
emitted by the current
Observable
, where that function returns an
ObservableSource
, and then emitting the items
that result from concatenating those returned
ObservableSource
s.
- concatMap(Function<? super T, ? extends ObservableSource<? extends R>>, int, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a new
Observable
that emits items resulting from applying a function that you supply to each item
emitted by the current
Observable
, where that function returns an
ObservableSource
, and then emitting the items
that result from concatenating those returned
ObservableSource
s.
- concatMap(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
that is based on applying a specified function to the item emitted by the current
Single
,
where that function returns a
SingleSource
.
- concatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and concatenates
Publisher
s on each 'rail', signalling errors immediately
and generating 2 publishers upfront.
- concatMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and concatenates
Publisher
s on each 'rail', signalling errors immediately
and using the given prefetch amount for generating
Publisher
s upfront.
- concatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other completes.
- concatMapCompletable(Function<? super T, ? extends CompletableSource>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other completes.
- concatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Completable
that completes based on applying a specified function to the item emitted by the
current
Maybe
, where that function returns a
Completable
.
- concatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
CompletableSource
s, subscribes to them one at a time in
order and waits until the upstream and all
CompletableSource
s complete.
- concatMapCompletable(Function<? super T, ? extends CompletableSource>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
CompletableSource
s, subscribes to them one at a time in
order and waits until the upstream and all
CompletableSource
s complete.
- concatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Completable
that completes based on applying a specified function to the item emitted by the
current
Single
, where that function returns a
CompletableSource
.
- concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other terminates, delaying all errors till both this
Flowable
and all
inner
CompletableSource
s terminate.
- concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other terminates, optionally delaying all errors till both this
Flowable
and all
inner
CompletableSource
s terminate.
- concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other terminates, optionally delaying all errors till both this
Flowable
and all
inner
CompletableSource
s terminate.
- concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other terminates, delaying all errors till both the current
Observable
and all
inner
CompletableSource
s terminate.
- concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other terminates, optionally delaying all errors till both the current
Observable
and all
inner
CompletableSource
s terminate.
- concatMapCompletableDelayError(Function<? super T, ? extends CompletableSource>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
CompletableSource
s and subscribes to them one after the
other terminates, optionally delaying all errors till both the current
Observable
and all
inner
CompletableSource
s terminate.
- concatMapDelayError(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each of the items into a
Publisher
, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner
Publisher
s
till all of them terminate.
- concatMapDelayError(Function<? super T, ? extends Publisher<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each of the items into a
Publisher
, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner
Publisher
s
till all of them terminate.
- concatMapDelayError(Function<? super T, ? extends Publisher<? extends R>>, boolean, int, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each of the upstream items into a
Publisher
, subscribes to them one after the other,
one at a time and emits their values in order
while executing the mapper function on the designated scheduler, delaying any error from either this or any of the
inner
Publisher
s till all of them terminate.
- concatMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each of the items into an
ObservableSource
, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner
ObservableSource
s
till all of them terminate.
- concatMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each of the items into an
ObservableSource
, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner
ObservableSource
s
till all of them terminate.
- concatMapDelayError(Function<? super T, ? extends ObservableSource<? extends R>>, boolean, int, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each of the items into an
ObservableSource
, subscribes to them one after the other,
one at a time and emits their values in order
while delaying any error from either this or any of the inner
ObservableSource
s
till all of them terminate.
- concatMapDelayError(Function<? super T, ? extends Publisher<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and concatenates
Publisher
s on each 'rail', optionally delaying errors
and generating 2 publishers upfront.
- concatMapDelayError(Function<? super T, ? extends Publisher<? extends R>>, int, boolean) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and concatenates
Publisher
s on each 'rail', optionally delaying errors
and using the given prefetch amount for generating
Publisher
s upfront.
- concatMapEager(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps a sequence of values into
Publisher
s and concatenates these
Publisher
s eagerly into a single
Publisher
.
- concatMapEager(Function<? super T, ? extends Publisher<? extends R>>, int, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps a sequence of values into
Publisher
s and concatenates these
Publisher
s eagerly into a single
Publisher
.
- concatMapEager(Function<? super T, ? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps a sequence of values into
ObservableSource
s and concatenates these
ObservableSource
s eagerly into a single
Observable
sequence.
- concatMapEager(Function<? super T, ? extends ObservableSource<? extends R>>, int, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps a sequence of values into
ObservableSource
s and concatenates these
ObservableSource
s eagerly into a single
Observable
sequence.
- concatMapEagerDelayError(Function<? super T, ? extends Publisher<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps a sequence of values into
Publisher
s and concatenates these
Publisher
s eagerly into a single
Publisher
.
- concatMapEagerDelayError(Function<? super T, ? extends Publisher<? extends R>>, boolean, int, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps a sequence of values into
Publisher
s and concatenates these
Publisher
s eagerly into a single
Flowable
sequence.
- concatMapEagerDelayError(Function<? super T, ? extends ObservableSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps a sequence of values into
ObservableSource
s and concatenates these
ObservableSource
s eagerly into a single
Observable
sequence.
- concatMapEagerDelayError(Function<? super T, ? extends ObservableSource<? extends R>>, boolean, int, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps a sequence of values into
ObservableSource
s and concatenates these
ObservableSource
s eagerly into a single
Observable
sequence.
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that concatenate each item emitted by the current
Flowable
with the values in an
Iterable
corresponding to that item that is generated by a selector.
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that concatenate each item emitted by the current
Flowable
with the values in an
Iterable
corresponding to that item that is generated by a selector.
- concatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that concatenate each item emitted by the current
Observable
with the values in an
Iterable
corresponding to that item that is generated by a selector.
- concatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either this
Flowable
or the current inner
MaybeSource
fail.
- concatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either this
Flowable
or the current inner
MaybeSource
fail.
- concatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either the current
Observable
or the current inner
MaybeSource
fail.
- concatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either the current
Observable
or the current inner
MaybeSource
fail.
- concatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Maybe
that is based on applying a specified function to the item emitted by the current
Single
,
where that function returns a
MaybeSource
.
- concatMapMaybeDelayError(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other terminates, emits their success value if available and delaying all errors
till both this
Flowable
and all inner
MaybeSource
s terminate.
- concatMapMaybeDelayError(Function<? super T, ? extends MaybeSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both this
Flowable
and all inner
MaybeSource
s terminate.
- concatMapMaybeDelayError(Function<? super T, ? extends MaybeSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both this
Flowable
and all inner
MaybeSource
s terminate.
- concatMapMaybeDelayError(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other terminates, emits their success value if available and delaying all errors
till both the current
Observable
and all inner
MaybeSource
s terminate.
- concatMapMaybeDelayError(Function<? super T, ? extends MaybeSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both the current
Observable
and all inner
MaybeSource
s terminate.
- concatMapMaybeDelayError(Function<? super T, ? extends MaybeSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
MaybeSource
s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both the current
Observable
and all inner
MaybeSource
s terminate.
- concatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either this
Flowable
or the current inner
SingleSource
fail.
- concatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either this
Flowable
or the current inner
SingleSource
fail.
- concatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
based on applying a specified function to the item emitted by the
current
Maybe
, where that function returns a
Single
.
- concatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either the current
Observable
or the current inner
SingleSource
fail.
- concatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either the current
Observable
or the current inner
SingleSource
fail.
- concatMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds or fails, emits their success values and delays all errors
till both this
Flowable
and all inner
SingleSource
s terminate.
- concatMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays all errors
till both this
Flowable
and all inner
SingleSource
s terminate.
- concatMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays errors
till both this
Flowable
and all inner
SingleSource
s terminate.
- concatMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds or fails, emits their success values and delays all errors
till both the current
Observable
and all inner
SingleSource
s terminate.
- concatMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays all errors
till both the current
Observable
and all inner
SingleSource
s terminate.
- concatMapSingleDelayError(Function<? super T, ? extends SingleSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps the upstream items into
SingleSource
s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays errors
till both the current
Observable
and all inner
SingleSource
s terminate.
- concatMapStream(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each upstream item into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- concatMapStream(Function<? super T, ? extends Stream<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each upstream item into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- concatMapStream(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each upstream item into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- concatWith(CompletableSource) - Method in class io.reactivex.rxjava3.core.Completable
-
- concatWith(Publisher<? extends T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits the items emitted from the current Flowable
, then the next, one after
the other, without interleaving them.
- concatWith(SingleSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items from this
Flowable
followed by the success item or error event
of the other
SingleSource
.
- concatWith(MaybeSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the items from this
Flowable
followed by the success item or terminal events
of the other
MaybeSource
.
- concatWith(CompletableSource) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits items from this
Flowable
and when it completes normally, the
other
CompletableSource
is subscribed to and the returned
Flowable
emits its terminal events.
- concatWith(MaybeSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Flowable
that emits the items emitted from the current
Maybe
, then the
other
MaybeSource
, one after
the other, without interleaving them.
- concatWith(ObservableSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that first emits the items emitted from the current
Observable
, then items
from the
other
ObservableSource
without interleaving them.
- concatWith(SingleSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items from the current
Observable
followed by the success item or error event
of the
other
SingleSource
.
- concatWith(MaybeSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the items from the current
Observable
followed by the success item or terminal events
of the other
MaybeSource
.
- concatWith(CompletableSource) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits items from the current
Observable
and when it completes normally, the
other
CompletableSource
is subscribed to and the returned
Observable
emits its terminal events.
- concatWith(SingleSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Flowable
that emits the item emitted by the current
Single
, then the item emitted by the
specified
SingleSource
.
- ConditionalSubscriber<T> - Interface in io.reactivex.rxjava3.operators
-
- connect(Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.flowables.ConnectableFlowable
-
Instructs the
ConnectableFlowable
to begin emitting the items from its underlying
Flowable
to its
Subscriber
s.
- connect() - Method in class io.reactivex.rxjava3.flowables.ConnectableFlowable
-
Instructs the
ConnectableFlowable
to begin emitting the items from its underlying
Flowable
to its
Subscriber
s.
- connect(Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.observables.ConnectableObservable
-
Instructs the
ConnectableObservable
to begin emitting the items from its underlying
Observable
to its
Observer
s.
- connect() - Method in class io.reactivex.rxjava3.observables.ConnectableObservable
-
Instructs the
ConnectableObservable
to begin emitting the items from its underlying
Observable
to its
Observer
s.
- ConnectableFlowable<T> - Class in io.reactivex.rxjava3.flowables
-
- ConnectableFlowable() - Constructor for class io.reactivex.rxjava3.flowables.ConnectableFlowable
-
- ConnectableObservable<T> - Class in io.reactivex.rxjava3.observables
-
- ConnectableObservable() - Constructor for class io.reactivex.rxjava3.observables.ConnectableObservable
-
- Consumer<T> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that accepts a single value.
- contains(Object) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that emits a
Boolean
that indicates whether the current
Flowable
emitted a
specified item.
- contains(Object) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Single
that emits a
Boolean
that indicates whether the current
Maybe
emitted a
specified item.
- contains(Object) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that emits a
Boolean
that indicates whether the current
Observable
emitted a
specified item.
- contains(Object) - Method in class io.reactivex.rxjava3.core.Single
-
Signals
true
if the current
Single
signals a success value that is
Object.equals(Object)
with the value
provided.
- contains(Object, BiPredicate<Object, Object>) - Method in class io.reactivex.rxjava3.core.Single
-
Signals
true
if the current
Single
signals a success value that is equal with
the value provided by calling a
BiPredicate
.
- count() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that counts the total number of items emitted by the current
Flowable
and emits
this count as a 64-bit
Long
.
- count() - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Single
that counts the total number of items emitted (0 or 1) by the current
Maybe
and emits
this count as a 64-bit
Long
.
- count() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that counts the total number of items emitted by the current
Observable
and emits
this count as a 64-bit
Long
.
- create(CompletableOnSubscribe) - Static method in class io.reactivex.rxjava3.core.Completable
-
Provides an API (via a cold Completable
) that bridges the reactive world with the callback-style world.
- create(FlowableOnSubscribe<T>, BackpressureStrategy) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Provides an API (via a cold Flowable
) that bridges the reactive world with the callback-style,
generally non-backpressured world.
- create(MaybeOnSubscribe<T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Provides an API (via a cold Maybe
) that bridges the reactive world with the callback-style world.
- create(ObservableOnSubscribe<T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Provides an API (via a cold Observable
) that bridges the reactive world with the callback-style world.
- create(SingleOnSubscribe<T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Provides an API (via a cold Single
) that bridges the reactive world with the callback-style world.
- create() - Static method in class io.reactivex.rxjava3.observers.TestObserver
-
Constructs a non-forwarding TestObserver
.
- create(Observer<? super T>) - Static method in class io.reactivex.rxjava3.observers.TestObserver
-
Constructs a forwarding TestObserver
.
- create() - Static method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
Creates a new AsyncProcessor.
- create() - Static method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- create() - Static method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
Constructs a fresh instance with the default Flowable.bufferSize() prefetch
amount and no refCount-behavior.
- create(boolean) - Static method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
Constructs a fresh instance with the default Flowable.bufferSize() prefetch
amount and the optional refCount-behavior.
- create(int) - Static method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
Constructs a fresh instance with the given prefetch amount and no refCount behavior.
- create(int, boolean) - Static method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
Constructs a fresh instance with the given prefetch amount and the optional
refCount-behavior.
- create() - Static method in class io.reactivex.rxjava3.processors.PublishProcessor
-
Constructs a PublishProcessor.
- create() - Static method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Creates an unbounded ReplayProcessor.
- create(int) - Static method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Creates an unbounded ReplayProcessor with the specified initial buffer capacity.
- create() - Static method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
Creates an UnicastSubject with an internal buffer capacity hint 16.
- create(int) - Static method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
Creates an UnicastProcessor with the given internal buffer capacity hint.
- create(boolean) - Static method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
Creates an UnicastProcessor with default internal buffer capacity hint and delay error flag.
- create(int, Runnable) - Static method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
Creates an UnicastProcessor with the given internal buffer capacity hint and a callback for
the case when the single Subscriber cancels its subscription or the
processor is terminated.
- create(int, Runnable, boolean) - Static method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
Creates an UnicastProcessor with the given internal buffer capacity hint, delay error flag and a callback for
the case when the single Subscriber cancels its subscription or
the processor is terminated.
- create() - Static method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
Creates a new AsyncProcessor.
- create() - Static method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- create() - Static method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
Creates a fresh CompletableSubject.
- create() - Static method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Creates a fresh MaybeSubject.
- create() - Static method in class io.reactivex.rxjava3.subjects.PublishSubject
-
Constructs a PublishSubject.
- create() - Static method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Creates an unbounded replay subject.
- create(int) - Static method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Creates an unbounded replay subject with the specified initial buffer capacity.
- create() - Static method in class io.reactivex.rxjava3.subjects.SingleSubject
-
Creates a fresh SingleSubject.
- create() - Static method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
Creates an UnicastSubject with an internal buffer capacity hint 16.
- create(int) - Static method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint.
- create(int, Runnable) - Static method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint and a callback for
the case when the single Subscriber cancels its subscription
or the subject is terminated.
- create(int, Runnable, boolean) - Static method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
Creates an UnicastSubject with the given internal buffer capacity hint, delay error flag and
a callback for the case when the single Observer disposes its
Disposable
or the subject is terminated.
- create(boolean) - Static method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
Creates an UnicastSubject with an internal buffer capacity hint 16 and given delay error flag.
- create() - Static method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- create(long) - Static method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
Creates a TestSubscriber
with the given initial request amount.
- create(Subscriber<? super T>) - Static method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
Constructs a forwarding TestSubscriber
.
- createComputationScheduler(ThreadFactory) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
- createDefault() - Static method in exception io.reactivex.rxjava3.exceptions.MissingBackpressureException
-
- createDefault(T) - Static method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- createDefault(T) - Static method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
Creates a
BehaviorSubject
that emits the last item it observed and all subsequent items to each
Observer
that subscribes to it.
- createExecutorScheduler(Executor, boolean, boolean) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
- createIoScheduler(ThreadFactory) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
- createNewThreadScheduler(ThreadFactory) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
- createOnComplete() - Static method in class io.reactivex.rxjava3.core.Notification
-
Returns the empty and stateless shared instance of a notification representing
an onComplete
signal.
- createOnError(Throwable) - Static method in class io.reactivex.rxjava3.core.Notification
-
Constructs an onError notification containing the error.
- createOnNext(T) - Static method in class io.reactivex.rxjava3.core.Notification
-
Constructs an onNext notification containing the given value.
- createSingleScheduler(ThreadFactory) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
- createWithSize(int) - Static method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Creates a size-bounded ReplayProcessor.
- createWithSize(int) - Static method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Creates a size-bounded replay subject.
- createWithTime(long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Creates a time-bounded ReplayProcessor.
- createWithTime(long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Creates a time-bounded replay subject.
- createWithTimeAndSize(long, TimeUnit, Scheduler, int) - Static method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Creates a time- and size-bounded ReplayProcessor.
- createWithTimeAndSize(long, TimeUnit, Scheduler, int) - Static method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Creates a time- and size-bounded replay subject.
- createWorker() - Method in class io.reactivex.rxjava3.core.Scheduler
-
Retrieves or creates a new
Scheduler.Worker
that represents sequential execution of actions.
- createWorker() - Method in class io.reactivex.rxjava3.schedulers.TestScheduler
-
- CUSTOM - Static variable in annotation type io.reactivex.rxjava3.annotations.SchedulerSupport
-
A special value indicating the operator/class requires a scheduler to be manually specified.
- debounce(Function<? super T, ? extends Publisher<U>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that mirrors the current Flowable
, except that it drops items emitted by the
current Flowable
that are followed by another item within a computed debounce duration.
- debounce(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that mirrors the current Flowable
, except that it drops items emitted by the
current Flowable
that are followed by newer items before a timeout value expires.
- debounce(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that mirrors the current
Flowable
, except that it drops items emitted by the
current
Flowable
that are followed by newer items before a timeout value expires on a specified
Scheduler
.
- debounce(long, TimeUnit, Scheduler, Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that mirrors the current
Flowable
, except that it drops items emitted by the
current
Flowable
that are followed by newer items before a timeout value expires on a specified
Scheduler
.
- debounce(Function<? super T, ? extends ObservableSource<U>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that mirrors the current
Observable
, except that it drops items emitted by the
current
Observable
that are followed by another item within a computed debounce duration
denoted by an item emission or completion from a generated inner
ObservableSource
for that original item.
- debounce(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that mirrors the current Observable
, except that it drops items emitted by the
current Observable
that are followed by newer items before a timeout value expires.
- debounce(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that mirrors the current
Observable
, except that it drops items emitted by the
current
Observable
that are followed by newer items before a timeout value expires on a specified
Scheduler
.
- debounce(long, TimeUnit, Scheduler, Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that mirrors the current
Observable
, except that it drops items emitted by the
current
Observable
that are followed by newer items before a timeout value expires on a specified
Scheduler
.
- DEFAULT_MESSAGE - Static variable in exception io.reactivex.rxjava3.exceptions.MissingBackpressureException
-
The default error message.
- defaultIfEmpty(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits the items emitted by the current Flowable
or a specified default item
if the current Flowable
is empty.
- defaultIfEmpty(T) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Single
that emits the item emitted by the current
Maybe
or a specified default item
if the current
Maybe
is empty.
- defaultIfEmpty(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits the items emitted by the current Observable
or a specified default item
if the current Observable
is empty.
- DefaultObserver<T> - Class in io.reactivex.rxjava3.observers
-
- DefaultObserver() - Constructor for class io.reactivex.rxjava3.observers.DefaultObserver
-
- DefaultSubscriber<T> - Class in io.reactivex.rxjava3.subscribers
-
- DefaultSubscriber() - Constructor for class io.reactivex.rxjava3.subscribers.DefaultSubscriber
-
- defer(Supplier<? extends CompletableSource>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Defers the subscription to a Completable
instance returned by a supplier.
- defer(Supplier<? extends Publisher<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that calls a
Publisher
factory to create a
Publisher
for each new
Subscriber
that subscribes.
- defer(Supplier<? extends MaybeSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- defer(Supplier<? extends ObservableSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that calls an
ObservableSource
factory to create an
ObservableSource
for each new
Observer
that subscribes.
- defer(Supplier<? extends SingleSource<? extends T>>) - Static method in class io.reactivex.rxjava3.core.Single
-
- delay(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
which delays the emission of the completion event by the given time.
- delay(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which delays the emission of the completion event by the given time while
running on the specified
Scheduler
.
- delay(long, TimeUnit, Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which delays the emission of the completion event, and optionally the error as well, by the given time while
running on the specified
Scheduler
.
- delay(Function<? super T, ? extends Publisher<U>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that delays the emissions of the current
Flowable
via another
Publisher
on a
per-item basis.
- delay(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits the items emitted by the current Flowable
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits the items emitted by the current Flowable
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits the items emitted by the current Flowable
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits the items emitted by the current Flowable
shifted forward in time by a
specified delay.
- delay(Publisher<U>, Function<? super T, ? extends Publisher<V>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that delays the subscription to and emissions from the current
Flowable
via another
Publisher
on a per-item basis.
- delay(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
that signals the events emitted by the current Maybe
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, boolean) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
that signals the events emitted by the current Maybe
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
that signals the events emitted by the current Maybe
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that signals the events emitted by the current
Maybe
shifted forward in time by a
specified delay running on the specified
Scheduler
.
- delay(Publisher<U>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Delays the emission of this
Maybe
until the given
Publisher
signals an item or completes.
- delay(Function<? super T, ? extends ObservableSource<U>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that delays the emissions of the current
Observable
via
a per-item derived
ObservableSource
's item emission or termination, on a per source item basis.
- delay(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits the items emitted by the current Observable
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits the items emitted by the current Observable
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits the items emitted by the current Observable
shifted forward in time by a
specified delay.
- delay(long, TimeUnit, Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits the items emitted by the current Observable
shifted forward in time by a
specified delay.
- delay(ObservableSource<U>, Function<? super T, ? extends ObservableSource<V>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that delays the subscription to and emissions from the current
Observable
via
ObservableSource
s for the subscription itself and on a per-item basis.
- delay(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the emission of the success signal from the current Single
by the specified amount.
- delay(long, TimeUnit, boolean) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the emission of the success or error signal from the current Single
by the specified amount.
- delay(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the emission of the success signal from the current Single
by the specified amount.
- delay(long, TimeUnit, Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the emission of the success or error signal from the current Single
by the specified amount.
- delaySubscription(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a Completable
that delays the subscription to the upstream by a given amount of time.
- delaySubscription(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
that delays the subscription to the upstream by a given amount of time,
both waiting and subscribing on a given
Scheduler
.
- delaySubscription(Publisher<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that delays the subscription to this
Publisher
until the other
Publisher
emits an element or completes normally.
- delaySubscription(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that delays the subscription to the current Flowable
by a given amount of time.
- delaySubscription(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that delays the subscription to the current
Flowable
by a given amount of time,
both waiting and subscribing on a given
Scheduler
.
- delaySubscription(Publisher<U>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that delays the subscription to this
Maybe
until the other
Publisher
emits an element or completes normally.
- delaySubscription(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
that delays the subscription to the current Maybe
by a given amount of time.
- delaySubscription(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that delays the subscription to the current
Maybe
by a given amount of time,
both waiting and subscribing on a given
Scheduler
.
- delaySubscription(ObservableSource<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that delays the subscription to the current
Observable
until the other
ObservableSource
emits an element or completes normally.
- delaySubscription(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that delays the subscription to the current Observable
by a given amount of time.
- delaySubscription(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that delays the subscription to the current
Observable
by a given amount of time,
both waiting and subscribing on a given
Scheduler
.
- delaySubscription(CompletableSource) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the actual subscription to the current
Single
until the given other
CompletableSource
completes.
- delaySubscription(SingleSource<U>) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the actual subscription to the current
Single
until the given other
SingleSource
signals success.
- delaySubscription(ObservableSource<U>) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the actual subscription to the current
Single
until the given other
ObservableSource
signals its first value or completes.
- delaySubscription(Publisher<U>) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the actual subscription to the current
Single
until the given other
Publisher
signals its first value or completes.
- delaySubscription(long, TimeUnit) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the actual subscription to the current Single
until the given time delay elapsed.
- delaySubscription(long, TimeUnit, Scheduler) - Method in class io.reactivex.rxjava3.core.Single
-
Delays the actual subscription to the current Single
until the given time delay elapsed.
- delete(Disposable) - Method in class io.reactivex.rxjava3.disposables.CompositeDisposable
-
Removes (but does not dispose) the given
Disposable
if it is part of this
container.
- delete(Disposable) - Method in interface io.reactivex.rxjava3.disposables.DisposableContainer
-
Removes but does not dispose the given disposable if it is part of this
container.
- dematerialize(Function<? super T, Notification<R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that reverses the effect of
materialize
by transforming the
Notification
objects extracted from the source items via a selector function
into their respective
Subscriber
signal types.
- dematerialize(Function<? super T, Notification<R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Maps the
Notification
success value of the current
Maybe
back into normal
onSuccess
,
onError
or
onComplete
signals.
- dematerialize(Function<? super T, Notification<R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that reverses the effect of
materialize
by transforming the
Notification
objects extracted from the source items via a selector function
into their respective
Observer
signal types.
- dematerialize(Function<? super T, Notification<R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Maps the
Notification
success value of the current
Single
back into normal
onSuccess
,
onError
or
onComplete
signals as a
Maybe
source.
- Disposable - Interface in io.reactivex.rxjava3.disposables
-
Represents a disposable resource.
- DisposableCompletableObserver - Class in io.reactivex.rxjava3.observers
-
An abstract
CompletableObserver
that allows asynchronous cancellation by implementing Disposable.
- DisposableCompletableObserver() - Constructor for class io.reactivex.rxjava3.observers.DisposableCompletableObserver
-
- DisposableContainer - Interface in io.reactivex.rxjava3.disposables
-
Common interface to add and remove disposables from a container.
- DisposableMaybeObserver<T> - Class in io.reactivex.rxjava3.observers
-
- DisposableMaybeObserver() - Constructor for class io.reactivex.rxjava3.observers.DisposableMaybeObserver
-
- DisposableObserver<T> - Class in io.reactivex.rxjava3.observers
-
- DisposableObserver() - Constructor for class io.reactivex.rxjava3.observers.DisposableObserver
-
- DisposableSingleObserver<T> - Class in io.reactivex.rxjava3.observers
-
- DisposableSingleObserver() - Constructor for class io.reactivex.rxjava3.observers.DisposableSingleObserver
-
- DisposableSubscriber<T> - Class in io.reactivex.rxjava3.subscribers
-
An abstract Subscriber that allows asynchronous, external cancellation by implementing
Disposable
.
- DisposableSubscriber() - Constructor for class io.reactivex.rxjava3.subscribers.DisposableSubscriber
-
- dispose() - Method in class io.reactivex.rxjava3.disposables.CompositeDisposable
-
- dispose() - Method in interface io.reactivex.rxjava3.disposables.Disposable
-
Dispose the resource, the operation should be idempotent.
- dispose() - Method in class io.reactivex.rxjava3.disposables.SerialDisposable
-
- dispose() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Cancel/dispose this test consumer.
- dispose() - Method in class io.reactivex.rxjava3.observers.DisposableCompletableObserver
-
- dispose() - Method in class io.reactivex.rxjava3.observers.DisposableMaybeObserver
-
- dispose() - Method in class io.reactivex.rxjava3.observers.DisposableObserver
-
- dispose() - Method in class io.reactivex.rxjava3.observers.DisposableSingleObserver
-
- dispose() - Method in class io.reactivex.rxjava3.observers.ResourceCompletableObserver
-
Cancels the main disposable (if any) and disposes the resources associated with
this ResourceCompletableObserver
(if any).
- dispose() - Method in class io.reactivex.rxjava3.observers.ResourceMaybeObserver
-
Cancels the main disposable (if any) and disposes the resources associated with
this ResourceMaybeObserver
(if any).
- dispose() - Method in class io.reactivex.rxjava3.observers.ResourceObserver
-
Cancels the main disposable (if any) and disposes the resources associated with
this ResourceObserver
(if any).
- dispose() - Method in class io.reactivex.rxjava3.observers.ResourceSingleObserver
-
Cancels the main disposable (if any) and disposes the resources associated with
this ResourceSingleObserver
(if any).
- dispose() - Method in class io.reactivex.rxjava3.observers.SafeObserver
-
- dispose() - Method in class io.reactivex.rxjava3.observers.SerializedObserver
-
- dispose() - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- dispose() - Method in class io.reactivex.rxjava3.subscribers.DisposableSubscriber
-
- dispose() - Method in class io.reactivex.rxjava3.subscribers.ResourceSubscriber
-
Cancels the subscription (if any) and disposes the resources associated with
this ResourceSubscriber
(if any).
- dispose() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- disposed() - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Returns a shared, disposed Disposable
instance.
- distinct() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits all items emitted by the current
Flowable
that are distinct
based on
Object.equals(Object)
comparison.
- distinct(Function<? super T, K>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits all items emitted by the current
Flowable
that are distinct according
to a key selector function and based on
Object.equals(Object)
comparison of the objects
returned by the key selector function.
- distinct(Function<? super T, K>, Supplier<? extends Collection<? super K>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits all items emitted by the current
Flowable
that are distinct according
to a key selector function and based on
Object.equals(Object)
comparison of the objects
returned by the key selector function.
- distinct() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits all items emitted by the current
Observable
that are distinct
based on
Object.equals(Object)
comparison.
- distinct(Function<? super T, K>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits all items emitted by the current
Observable
that are distinct according
to a key selector function and based on
Object.equals(Object)
comparison of the objects
returned by the key selector function.
- distinct(Function<? super T, K>, Supplier<? extends Collection<? super K>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits all items emitted by the current
Observable
that are distinct according
to a key selector function and based on
Object.equals(Object)
comparison of the objects
returned by the key selector function.
- distinctUntilChanged() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits all items emitted by the current
Flowable
that are distinct from their
immediate predecessors based on
Object.equals(Object)
comparison.
- distinctUntilChanged(Function<? super T, K>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits all items emitted by the current
Flowable
that are distinct from their
immediate predecessors, according to a key selector function and based on
Object.equals(Object)
comparison
of those objects returned by the key selector function.
- distinctUntilChanged(BiPredicate<? super T, ? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits all items emitted by the current Flowable
that are distinct from their
immediate predecessors when compared with each other via the provided comparator function.
- distinctUntilChanged() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits all items emitted by the current
Observable
that are distinct from their
immediate predecessors based on
Object.equals(Object)
comparison.
- distinctUntilChanged(Function<? super T, K>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits all items emitted by the current
Observable
that are distinct from their
immediate predecessors, according to a key selector function and based on
Object.equals(Object)
comparison
of those objects returned by the key selector function.
- distinctUntilChanged(BiPredicate<? super T, ? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits all items emitted by the current Observable
that are distinct from their
immediate predecessors when compared with each other via the provided comparator function.
- doAfterNext(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the specified consumer with the current item after this item has been emitted to the downstream.
- doAfterNext(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Calls the specified
Consumer
with the current item after this item has been emitted to the downstream.
- doAfterNext(Consumer<? super T>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified consumer with the current element passing through any 'rail'
after it has been delivered to downstream within the rail.
- doAfterSuccess(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Calls the specified
Consumer
with the success item after this item has been emitted to the downstream.
- doAfterSuccess(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the specified consumer with the success item after this item has been emitted to the downstream.
- doAfterTerminate(Action) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that calls the given
onAfterTerminate
Action
after this
Completable
completes normally or with an exception.
- doAfterTerminate(Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
- doAfterTerminate(Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
- doAfterTerminate(Action) - Method in class io.reactivex.rxjava3.core.Observable
-
- doAfterTerminate(Action) - Method in class io.reactivex.rxjava3.core.Single
-
Registers an
Action
to be called after this
Single
invokes either
onSuccess
or
onError
.
- doAfterTerminated(Action) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Run the specified
Action
when a 'rail' completes or signals an error.
- doFinally(Action) - Method in class io.reactivex.rxjava3.core.Completable
-
Calls the specified
Action
after this
Completable
signals
onError
or
onComplete
or gets disposed by
the downstream.
- doFinally(Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the specified action after this Flowable
signals onError
or onComplete
or gets canceled by
the downstream.
- doFinally(Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
Calls the specified action after this Maybe
signals onSuccess
, onError
or onComplete
or gets disposed by
the downstream.
- doFinally(Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Calls the specified action after the current Observable
signals onError
or onCompleted
or gets disposed by
the downstream.
- doFinally(Action) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the specified action after this Single
signals onSuccess
or onError
or gets disposed by
the downstream.
- done - Variable in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
The latch that indicates an onError or onComplete has been called.
- doOnCancel(Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the cancel
Action
if the downstream cancels the sequence.
- doOnCancel(Action) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Run the specified
Action
when a 'rail' receives a cancellation.
- doOnComplete(Action) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which calls the given
onComplete
Action
if this
Completable
completes.
- doOnComplete(Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Invokes an
Action
just before the current
Flowable
calls
onComplete
.
- doOnComplete(Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
Invokes an
Action
just before the current
Maybe
calls
onComplete
.
- doOnComplete(Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that invokes an
Action
when the current
Observable
calls
onComplete
.
- doOnComplete(Action) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Run the specified
Action
when a 'rail' completes.
- doOnDispose(Action) - Method in class io.reactivex.rxjava3.core.Completable
-
- doOnDispose(Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
- doOnDispose(Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Calls the given shared
Action
if the downstream disposes the sequence.
- doOnDispose(Action) - Method in class io.reactivex.rxjava3.core.Single
-
- doOnEach(Consumer<? super Notification<T>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Invokes a
Consumer
with a
Notification
instances matching the signals emitted by the current
Flowable
before they are forwarded to the downstream.
- doOnEach(Subscriber<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the appropriate methods of the given
Subscriber
when the current
Flowable
signals events before forwarding it
to the downstream.
- doOnEach(Consumer<? super Notification<T>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that invokes a
Consumer
with the appropriate
Notification
object when the current
Observable
signals an item or terminates.
- doOnEach(Observer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that forwards the items and terminal events of the current
Observable
to its
Observer
s and to the given shared
Observer
instance.
- doOnError(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which calls the given
onError
Consumer
if this
Completable
emits an error.
- doOnError(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the given
Consumer
with the error
Throwable
if the current
Flowable
failed before forwarding it to
the downstream.
- doOnError(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Calls the shared
Consumer
with the error sent via
onError
for each
MaybeObserver
that subscribes to the current
Maybe
.
- doOnError(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Observable
-
Calls the given
Consumer
with the error
Throwable
if the current
Observable
failed before forwarding it to
the downstream.
- doOnError(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the shared consumer with the error sent via
onError
for each
SingleObserver
that subscribes to the current
Single
.
- doOnError(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified consumer with the exception passing through any 'rail'.
- doOnEvent(Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which calls the given
onEvent
Consumer
with the
Throwable
for an
onError
or
null
for an
onComplete
signal from this
Completable
before delivering the signal to the downstream.
- doOnEvent(BiConsumer<? super T, ? super Throwable>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Calls the given onEvent
callback with the (success value, null
) for an onSuccess
, (null
, throwable) for
an onError
or (null
, null
) for an onComplete
signal from this Maybe
before delivering said
signal to the downstream.
- doOnEvent(BiConsumer<? super T, ? super Throwable>) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the shared consumer with the error sent via
onError
or the value
via
onSuccess
for each
SingleObserver
that subscribes to the current
Single
.
- doOnLifecycle(Consumer<? super Disposable>, Action) - Method in class io.reactivex.rxjava3.core.Completable
-
Calls the appropriate
onXXX
method (shared between all
CompletableObserver
s) for the lifecycle events of
the sequence (subscription, disposal).
- doOnLifecycle(Consumer<? super Subscription>, LongConsumer, Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the appropriate
onXXX
method (shared between all
Subscriber
s) for the lifecycle events of
the sequence (subscription, cancellation, requesting).
- doOnLifecycle(Consumer<? super Disposable>, Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
Calls the appropriate
onXXX
method (shared between all
MaybeObserver
s) for the lifecycle events of
the sequence (subscription, disposal).
- doOnLifecycle(Consumer<? super Disposable>, Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Calls the appropriate
onXXX
method (shared between all
Observer
s) for the lifecycle events of
the sequence (subscription, disposal).
- doOnLifecycle(Consumer<? super Disposable>, Action) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the appropriate
onXXX
method (shared between all
SingleObserver
s) for the lifecycle events of
the sequence (subscription, disposal).
- doOnNext(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the given
Consumer
with the value emitted by the current
Flowable
before forwarding it to the downstream.
- doOnNext(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Calls the given
Consumer
with the value emitted by the current
Observable
before forwarding it to the downstream.
- doOnNext(Consumer<? super T>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified consumer with the current element passing through any 'rail'.
- doOnNext(Consumer<? super T>, ParallelFailureHandling) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified consumer with the current element passing through any 'rail' and
handles errors based on the given
ParallelFailureHandling
enumeration value.
- doOnNext(Consumer<? super T>, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified consumer with the current element passing through any 'rail' and
handles errors based on the returned value by the handler function.
- doOnRequest(LongConsumer) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the given
LongConsumer
with the request amount from the downstream before forwarding it
to the current
Flowable
.
- doOnRequest(LongConsumer) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified consumer with the request amount if any rail receives a request.
- doOnSubscribe(Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that calls the given
onSubscribe
callback with the disposable
that the downstream
CompletableObserver
s receive upon subscription.
- doOnSubscribe(Consumer<? super Subscription>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the given
Consumer
with the
Subscription
provided by the current
Flowable
upon
subscription from the downstream before forwarding it to the subscriber's
onSubscribe
method.
- doOnSubscribe(Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.core.Maybe
-
- doOnSubscribe(Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
so that it invokes the given
Consumer
when the current
Observable
is subscribed from
its
Observer
s.
- doOnSubscribe(Consumer<? super Disposable>) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the shared consumer with the
Disposable
sent through the
onSubscribe
for each
SingleObserver
that subscribes to the current
Single
.
- doOnSubscribe(Consumer<? super Subscription>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Call the specified callback when a 'rail' receives a
Subscription
from its upstream.
- doOnSuccess(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Calls the shared
Consumer
with the success value sent via
onSuccess
for each
MaybeObserver
that subscribes to the current
Maybe
.
- doOnSuccess(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Single
-
Calls the shared consumer with the success value sent via
onSuccess
for each
SingleObserver
that subscribes to the current
Single
.
- doOnTerminate(Action) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that calls the given
onTerminate
Action
just before this
Completable
completes normally or with an exception.
- doOnTerminate(Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Calls the given
Action
when the current
Flowable
completes normally or with an error before those signals
are forwarded to the downstream.
- doOnTerminate(Action) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
instance that calls the given onTerminate callback
just before this Maybe
completes normally or with an exception.
- doOnTerminate(Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
so that it invokes an action when the current Observable
calls onComplete
or
onError
.
- doOnTerminate(Action) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a Single
instance that calls the given onTerminate
callback
just before this Single
completes normally or with an exception.
- fail(String) - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Fail with the given message and add the sequence of errors as suppressed ones.
- filter(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Filters items emitted by the current Flowable
by only emitting those that satisfy a specified predicate.
- filter(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Filters the success item of the Maybe
via a predicate function and emitting it if the predicate
returns true
, completing otherwise.
- filter(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Filters items emitted by the current
Observable
by only emitting those that satisfy a specified
Predicate
.
- filter(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Single
-
Filters the success item of the Single
via a predicate function and emitting it if the predicate
returns true
, completing otherwise.
- filter(Predicate<? super T>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Filters the source values on each 'rail'.
- filter(Predicate<? super T>, ParallelFailureHandling) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Filters the source values on each 'rail' and
handles errors based on the given
ParallelFailureHandling
enumeration value.
- filter(Predicate<? super T>, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Filters the source values on each 'rail' and
handles errors based on the returned value by the handler function.
- first(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that emits only the very first item emitted by this
Flowable
, or a default
item if this
Flowable
completes without emitting anything.
- first(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that emits only the very first item emitted by the current
Observable
, or a default item
if the current
Observable
completes without emitting any items.
- firstElement() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Maybe
that emits only the very first item emitted by this
Flowable
or
completes if this
Flowable
is empty.
- firstElement() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Maybe
that emits only the very first item emitted by the current
Observable
, or
completes if the current
Observable
is empty.
- firstOrError() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that emits only the very first item emitted by this
Flowable
or
signals a
NoSuchElementException
if this
Flowable
is empty.
- firstOrError() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that emits only the very first item emitted by the current
Observable
or
signals a
NoSuchElementException
if the current
Observable
is empty.
- firstOrErrorStage() - Method in class io.reactivex.rxjava3.core.Flowable
-
- firstOrErrorStage() - Method in class io.reactivex.rxjava3.core.Observable
-
- firstStage(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Signals the first upstream item (or the default item if the upstream is empty) via
a
CompletionStage
.
- firstStage(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Signals the first upstream item (or the default item if the upstream is empty) via
a
CompletionStage
.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits items based on applying a function that you supply to each item emitted
by the current
Flowable
, where that function returns a
Publisher
, and then merging those resulting
Publisher
s and emitting the results of this merger.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits items based on applying a function that you supply to each item emitted
by the current
Flowable
, where that function returns a
Publisher
, and then merging those resulting
Publisher
s and emitting the results of this merger.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits items based on applying a function that you supply to each item emitted
by the current
Flowable
, where that function returns a
Publisher
, and then merging those resulting
Publisher
s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits items based on applying a function that you supply to each item emitted
by the current
Flowable
, where that function returns a
Publisher
, and then merging those resulting
Publisher
s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits items based on applying a function that you supply to each item emitted
by the current
Flowable
, where that function returns a
Publisher
, and then merging those resulting
Publisher
s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, Function<? super Throwable, ? extends Publisher<? extends R>>, Supplier<? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that applies a function to each item emitted or notification raised by the current
Flowable
and then flattens the
Publisher
s returned from these functions and emits the resulting items.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, Function<Throwable, ? extends Publisher<? extends R>>, Supplier<? extends Publisher<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that applies a function to each item emitted or notification raised by the current
Flowable
and then flattens the
Publisher
s returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends U>>, BiFunction<? super T, ? super U, ? extends R>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the results of a specified function to the pair of values emitted by the
current
Flowable
and a specified collection
Publisher
.
- flatMap(Function<? super T, ? extends Publisher<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the results of a specified function to the pair of values emitted by the
current
Flowable
and a specified inner
Publisher
.
- flatMap(Function<? super T, ? extends Publisher<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the results of a specified function to the pair of values emitted by the
current
Flowable
and a specified collection
Publisher
, while limiting the maximum number of concurrent
subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, boolean, int, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the results of a specified function to the pair of values emitted by the
current
Flowable
and a specified collection
Publisher
, while limiting the maximum number of concurrent
subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits the results of a specified function to the pair of values emitted by the
current
Flowable
and a specified collection
Publisher
, while limiting the maximum number of concurrent
subscriptions to these
Publisher
s.
- flatMap(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that is based on applying a specified function to the item emitted by the current
Maybe
,
where that function returns a
MaybeSource
.
- flatMap(Function<? super T, ? extends MaybeSource<? extends R>>, Function<? super Throwable, ? extends MaybeSource<? extends R>>, Supplier<? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Maps the
onSuccess
,
onError
or
onComplete
signals of the current
Maybe
into a
MaybeSource
and emits that
MaybeSource
's signals.
- flatMap(Function<? super T, ? extends MaybeSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that emits the results of a specified function to the pair of values emitted by the
current
Maybe
and a specified mapped
MaybeSource
.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits items based on applying a function that you supply to each item emitted
by the current
Observable
, where that function returns an
ObservableSource
, and then merging those returned
ObservableSource
s and emitting the results of this merger.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits items based on applying a function that you supply to each item emitted
by the current
Observable
, where that function returns an
ObservableSource
, and then merging those returned
ObservableSource
s and emitting the results of this merger.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits items based on applying a function that you supply to each item emitted
by the current
Observable
, where that function returns an
ObservableSource
, and then merging those returned
ObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>, boolean, int, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits items based on applying a function that you supply to each item emitted
by the current
Observable
, where that function returns an
ObservableSource
, and then merging those returned
ObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>, Function<? super Throwable, ? extends ObservableSource<? extends R>>, Supplier<? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that applies a function to each item emitted or notification raised by the current
Observable
and then flattens the
ObservableSource
s returned from these functions and emits the resulting items.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>, Function<Throwable, ? extends ObservableSource<? extends R>>, Supplier<? extends ObservableSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that applies a function to each item emitted or notification raised by the current
Observable
and then flattens the
ObservableSource
s returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends ObservableSource<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits items based on applying a function that you supply to each item emitted
by the current
Observable
, where that function returns an
ObservableSource
, and then merging those returned
ObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends ObservableSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the results of a specified function to the pair of values emitted by the
current
Observable
and the mapped inner
ObservableSource
.
- flatMap(Function<? super T, ? extends ObservableSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the results of a specified function to the pair of values emitted by the
current
Observable
and the mapped inner
ObservableSource
.
- flatMap(Function<? super T, ? extends ObservableSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the results of a specified function to the pair of values emitted by the
current
Observable
and the mapped inner
ObservableSource
, while limiting the maximum number of concurrent
subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends ObservableSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, boolean, int, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the results of a specified function to the pair of values emitted by the
current
Observable
and the mapped inner
ObservableSource
, while limiting the maximum number of concurrent
subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends ObservableSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits the results of a specified function to the pair of values emitted by the
current
Observable
and the mapped inner
ObservableSource
, while limiting the maximum number of concurrent
subscriptions to these
ObservableSource
s.
- flatMap(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
that is based on applying a specified function to the item emitted by the current
Single
,
where that function returns a
SingleSource
.
- flatMap(Function<? super T, ? extends SingleSource<? extends U>>, BiFunction<? super T, ? super U, ? extends R>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
that emits the results of a specified function to the pair of values emitted by the
current
Single
and a specified mapped
SingleSource
.
- flatMap(Function<? super T, ? extends SingleSource<? extends R>>, Function<? super Throwable, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Maps the
onSuccess
or
onError
signals of the current
Single
into a
SingleSource
and emits that
SingleSource
's signals.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and flattens
Publisher
s on each 'rail'.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and flattens
Publisher
s on each 'rail', optionally delaying errors.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and flattens
Publisher
s on each 'rail', optionally delaying errors
and having a total number of simultaneous subscriptions to the inner
Publisher
s.
- flatMap(Function<? super T, ? extends Publisher<? extends R>>, boolean, int, int) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Generates and flattens
Publisher
s on each 'rail', optionally delaying errors,
having a total number of simultaneous subscriptions to the inner
Publisher
s
and using the given prefetch amount for the inner
Publisher
s.
- flatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each element of the upstream
Flowable
into
CompletableSource
s, subscribes to them and
waits until the upstream and all
CompletableSource
s complete.
- flatMapCompletable(Function<? super T, ? extends CompletableSource>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each element of the upstream
Flowable
into
CompletableSource
s, subscribes to them and
waits until the upstream and all
CompletableSource
s complete, optionally delaying all errors.
- flatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Completable
that completes based on applying a specified function to the item emitted by the
current
Maybe
, where that function returns a
Completable
.
- flatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
CompletableSource
s, subscribes to them and
waits until the upstream and all
CompletableSource
s complete.
- flatMapCompletable(Function<? super T, ? extends CompletableSource>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
CompletableSource
s, subscribes to them and
waits until the upstream and all
CompletableSource
s complete, optionally delaying all errors.
- flatMapCompletable(Function<? super T, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Completable
that completes based on applying a specified function to the item emitted by the
current
Single
, where that function returns a
CompletableSource
.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Merges
Iterable
s generated by a mapper
Function
for each individual item emitted by
the current
Flowable
into a single
Flowable
sequence.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Merges
Iterable
s generated by a mapper
Function
for each individual item emitted by
the current
Flowable
into a single
Flowable
sequence.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, BiFunction<? super T, ? super U, ? extends V>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Merges
Iterable
s generated by a mapper
Function
for each individual item emitted by
the current
Flowable
into a single
Flowable
sequence where the resulting items will
be the combination of the original item and each inner item of the respective
Iterable
as returned
by the
resultSelector
BiFunction
.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, BiFunction<? super T, ? super U, ? extends V>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Merges
Iterable
s generated by a mapper
Function
for each individual item emitted by
the current
Flowable
into a single
Flowable
sequence where the resulting items will
be the combination of the original item and each inner item of the respective
Iterable
as returned
by the
resultSelector
BiFunction
.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Merges
Iterable
s generated by a mapper
Function
for each individual item emitted by
the current
Observable
into a single
Observable
sequence.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, BiFunction<? super T, ? super U, ? extends V>) - Method in class io.reactivex.rxjava3.core.Observable
-
Merges
Iterable
s generated by a mapper
Function
for each individual item emitted by
the current
Observable
into a single
Observable
sequence where the resulting items will
be the combination of the original item and each inner item of the respective
Iterable
as returned
by the
resultSelector
BiFunction
.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Returns a
ParallelFlowable
that merges each item emitted by the source on each rail with the values in an
Iterable
corresponding to that item that is generated by a selector.
- flatMapIterable(Function<? super T, ? extends Iterable<? extends U>>, int) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Returns a
ParallelFlowable
that merges each item emitted by the source
ParallelFlowable
with the values in an
Iterable
corresponding to that item that is generated by a selector.
- flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each element of the upstream
Flowable
into
MaybeSource
s, subscribes to all of them
and merges their
onSuccess
values, in no particular order, into a single
Flowable
sequence.
- flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each element of the upstream
Flowable
into
MaybeSource
s, subscribes to at most
maxConcurrency
MaybeSource
s at a time and merges their
onSuccess
values,
in no particular order, into a single
Flowable
sequence, optionally delaying all errors.
- flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
MaybeSource
s, subscribes to all of them
and merges their
onSuccess
values, in no particular order, into a single
Observable
sequence.
- flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
MaybeSource
s, subscribes to them
and merges their
onSuccess
values, in no particular order, into a single
Observable
sequence,
optionally delaying all errors.
- flatMapMaybe(Function<? super T, ? extends MaybeSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Maybe
that is based on applying a specified function to the item emitted by the current
Single
,
where that function returns a
MaybeSource
.
- flatMapObservable(Function<? super T, ? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns an
Observable
that is based on applying a specified function to the item emitted by the current
Maybe
,
where that function returns an
ObservableSource
.
- flatMapObservable(Function<? super T, ? extends ObservableSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns an
Observable
that is based on applying a specified function to the item emitted by the current
Single
,
where that function returns an
ObservableSource
.
- flatMapPublisher(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Flowable
that emits items based on applying a specified function to the item emitted by the
current
Maybe
, where that function returns a
Publisher
.
- flatMapPublisher(Function<? super T, ? extends Publisher<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Flowable
that emits items based on applying a specified function to the item emitted by the
current
Single
, where that function returns a
Publisher
.
- flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each element of the upstream
Flowable
into
SingleSource
s, subscribes to all of them
and merges their
onSuccess
values, in no particular order, into a single
Flowable
sequence.
- flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each element of the upstream
Flowable
into
SingleSource
s, subscribes to at most
maxConcurrency
SingleSource
s at a time and merges their
onSuccess
values,
in no particular order, into a single
Flowable
sequence, optionally delaying all errors.
- flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
based on applying a specified function to the item emitted by the
current
Maybe
, where that function returns a
Single
.
- flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
SingleSource
s, subscribes to all of them
and merges their
onSuccess
values, in no particular order, into a single
Observable
sequence.
- flatMapSingle(Function<? super T, ? extends SingleSource<? extends R>>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each element of the current
Observable
into
SingleSource
s, subscribes to them
and merges their
onSuccess
values, in no particular order, into a single
Observable
sequence,
optionally delaying all errors.
- flatMapStream(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each upstream item into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- flatMapStream(Function<? super T, ? extends Stream<? extends R>>, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Maps each upstream item into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- flatMapStream(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Maps each upstream item into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- flatMapStream(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Maps each upstream item on each rail into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- flatMapStream(Function<? super T, ? extends Stream<? extends R>>, int) - Method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Maps each upstream item of each rail into a
Stream
and emits the
Stream
's items to the downstream in a sequential fashion.
- flattenAsFlowable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Maps the success value of the current
Maybe
into an
Iterable
and emits its items as a
Flowable
sequence.
- flattenAsFlowable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Single
-
Maps the success value of the current
Single
into an
Iterable
and emits its items as a
Flowable
sequence.
- flattenAsObservable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Maps the success value of the current
Maybe
into an
Iterable
and emits its items as an
Observable
sequence.
- flattenAsObservable(Function<? super T, ? extends Iterable<? extends U>>) - Method in class io.reactivex.rxjava3.core.Single
-
Maps the success value of the current
Single
into an
Iterable
and emits its items as an
Observable
sequence.
- flattenStreamAsFlowable(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Maps the upstream succecss value into a Java
Stream
and emits its
items to the downstream consumer as a
Flowable
.
- flattenStreamAsFlowable(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Maps the upstream succecss value into a Java
Stream
and emits its
items to the downstream consumer as a
Flowable
.
- flattenStreamAsObservable(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Maps the upstream succecss value into a Java
Stream
and emits its
items to the downstream consumer as an
Observable
.
- flattenStreamAsObservable(Function<? super T, ? extends Stream<? extends R>>) - Method in class io.reactivex.rxjava3.core.Single
-
Maps the upstream succecss value into a Java
Stream
and emits its
items to the downstream consumer as an
Observable
.
- Flowable<T> - Class in io.reactivex.rxjava3.core
-
The
Flowable
class that implements the
Reactive Streams Publisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
- Flowable() - Constructor for class io.reactivex.rxjava3.core.Flowable
-
- FlowableConverter<T,R> - Interface in io.reactivex.rxjava3.core
-
- FlowableEmitter<T> - Interface in io.reactivex.rxjava3.core
-
Abstraction over a Reactive Streams
Subscriber
that allows associating
a resource with it and exposes the current number of downstream
requested amount.
- FlowableOnSubscribe<T> - Interface in io.reactivex.rxjava3.core
-
A functional interface that has a
subscribe()
method that receives
a
FlowableEmitter
instance that allows pushing
events in a backpressure-safe and cancellation-safe manner.
- FlowableOperator<Downstream,Upstream> - Interface in io.reactivex.rxjava3.core
-
Interface to map/wrap a downstream
Subscriber
to an upstream
Subscriber
.
- FlowableProcessor<T> - Class in io.reactivex.rxjava3.processors
-
Represents a Subscriber and a Flowable (Publisher) at the same time, allowing
multicasting events from a single source to multiple child Subscribers.
- FlowableProcessor() - Constructor for class io.reactivex.rxjava3.processors.FlowableProcessor
-
- FlowableSubscriber<T> - Interface in io.reactivex.rxjava3.core
-
Represents a Reactive-Streams inspired
Subscriber
that is RxJava 3 only
and weakens the Reactive Streams rules
§1.3
and
§3.9 of the specification
for gaining performance.
- FlowableTransformer<Upstream,Downstream> - Interface in io.reactivex.rxjava3.core
-
- forEach(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the current Flowable
and receives notifications for each element.
- forEach(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
- forEachWhile(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the current Flowable
and receives notifications for each element until the
onNext
Predicate returns false
.
- forEachWhile(Predicate<? super T>, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the current Flowable
and receives notifications for each element and error events until the
onNext
Predicate returns false
.
- forEachWhile(Predicate<? super T>, Consumer<? super Throwable>, Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Subscribes to the current Flowable
and receives notifications for each element and the terminal events until the
onNext
Predicate returns false
.
- forEachWhile(Predicate<? super T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the
ObservableSource
and calls a
Predicate
for each item of the current
Observable
,
on its emission thread, until the predicate returns
false
.
- forEachWhile(Predicate<? super T>, Consumer<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the
ObservableSource
and calls a
Predicate
for each item or a
Consumer
with the error
of the current
Observable
, on their original emission threads, until the predicate returns
false
.
- forEachWhile(Predicate<? super T>, Consumer<? super Throwable>, Action) - Method in class io.reactivex.rxjava3.core.Observable
-
Subscribes to the
ObservableSource
and calls a
Predicate
for each item, a
Consumer
with the error
or an
Action
upon completion of the current
Observable
, on their original emission threads,
until the predicate returns
false
.
- from(Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Take a
Publisher
and prepare to consume it on multiple 'rails' (number of CPUs)
in a round-robin fashion.
- from(Publisher<? extends T>, int) - Static method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Take a
Publisher
and prepare to consume it on parallelism number of 'rails' in a round-robin fashion.
- from(Publisher<? extends T>, int, int) - Static method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Take a
Publisher
and prepare to consume it on parallelism number of 'rails' ,
possibly ordered and round-robin fashion and use custom prefetch amount and queue
for dealing with the source
Publisher
's values.
- from(Executor) - Static method in class io.reactivex.rxjava3.schedulers.Schedulers
-
Wraps an
Executor
into a new
Scheduler
instance and delegates
schedule()
calls to it.
- from(Executor, boolean) - Static method in class io.reactivex.rxjava3.schedulers.Schedulers
-
Wraps an
Executor
into a new
Scheduler
instance and delegates
schedule()
calls to it.
- from(Executor, boolean, boolean) - Static method in class io.reactivex.rxjava3.schedulers.Schedulers
-
Wraps an
Executor
into a new
Scheduler
instance and delegates
schedule()
calls to it.
- fromAction(Action) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that runs the given
Action
for each
CompletableObserver
and
emits either an exception or simply completes.
- fromAction(Action) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
instance that runs the given
Action
for each
Subscriber
and
emits either its exception or simply completes.
- fromAction(Action) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
instance that runs the given
Action
for each
MaybeObserver
and
emits either its exception or simply completes.
- fromAction(Action) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
instance that runs the given
Action
for each
Observer
and
emits either its exception or simply completes.
- fromAction(Action) - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Construct a
Disposable
by wrapping a
Action
that is
executed exactly once when the
Disposable
is disposed.
- fromArray(T...) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Converts an array into a
Publisher
that emits the items in the array.
- fromArray(T...) - Static method in class io.reactivex.rxjava3.core.Observable
-
- fromArray(Publisher<T>...) - Static method in class io.reactivex.rxjava3.parallel.ParallelFlowable
-
Wraps multiple
Publisher
s into a
ParallelFlowable
which runs them
in parallel and unordered.
- fromAutoCloseable(AutoCloseable) - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Construct a
Disposable
by wrapping an
AutoCloseable
that is
closed exactly once when the
Disposable
is disposed.
- fromCallable(Callable<?>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which when subscribed, executes the
Callable
function, ignores its
normal result and emits
onError
or
onComplete
only.
- fromCallable(Callable<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that, when a
Subscriber
subscribes to it, invokes a function you specify and then
emits the value returned from that function.
- fromCallable(Callable<? extends T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that invokes the given
Callable
for each individual
MaybeObserver
that
subscribes and emits the resulting non-
null
item via
onSuccess
while
considering a
null
result from the
Callable
as indication for valueless completion
via
onComplete
.
- fromCallable(Callable<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that, when an observer subscribes to it, invokes a function you specify and then
emits the value returned from that function.
- fromCallable(Callable<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
that invokes the given
Callable
for each incoming
SingleObserver
and emits its value or exception to them.
- fromCompletable(CompletableSource) - Static method in class io.reactivex.rxjava3.core.Flowable
-
- fromCompletable(CompletableSource) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- fromCompletable(CompletableSource) - Static method in class io.reactivex.rxjava3.core.Observable
-
- fromCompletionStage(CompletionStage<?>) - Static method in class io.reactivex.rxjava3.core.Completable
-
- fromCompletionStage(CompletionStage<T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Signals the completion value or error of the given (hot)
CompletionStage
-based asynchronous calculation.
- fromCompletionStage(CompletionStage<T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Signals the completion value or error of the given (hot)
CompletionStage
-based asynchronous calculation.
- fromCompletionStage(CompletionStage<T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Signals the completion value or error of the given (hot)
CompletionStage
-based asynchronous calculation.
- fromCompletionStage(CompletionStage<T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Signals the completion value or error of the given (hot)
CompletionStage
-based asynchronous calculation.
- fromFuture(Future<?>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that reacts to the termination of the given
Future
in a blocking fashion.
- fromFuture(Future<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
- fromFuture(Future<? extends T>, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Flowable
-
- fromFuture(Future<? extends T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Converts a
Future
into a
Maybe
, treating a
null
result as an indication of emptiness.
- fromFuture(Future<? extends T>, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Converts a
Future
into a
Maybe
, with a timeout on the
Future
.
- fromFuture(Future<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Converts a
Future
into an
Observable
.
- fromFuture(Future<? extends T>, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Observable
-
Converts a
Future
into an
Observable
, with a timeout on the
Future
.
- fromFuture(Future<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Converts a
Future
into a
Single
and awaits its outcome in a blocking fashion.
- fromFuture(Future<? extends T>, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Single
-
Converts a
Future
into a
Single
and awaits its outcome, or timeout, in a blocking fashion.
- fromFuture(Future<?>) - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Construct a
Disposable
by wrapping a
Future
that is
cancelled exactly once when the
Disposable
is disposed.
- fromFuture(Future<?>, boolean) - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Construct a
Disposable
by wrapping a
Future
that is
cancelled exactly once when the
Disposable
is disposed.
- fromIterable(Iterable<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
- fromIterable(Iterable<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Converts an
Iterable
sequence into an
Observable
that emits the items in the sequence.
- fromMaybe(MaybeSource<T>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that when subscribed to, subscribes to the
MaybeSource
instance and
emits an
onComplete
event if the maybe emits
onSuccess
/
onComplete
or forwards any
onError
events.
- fromMaybe(MaybeSource<T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
instance that when subscribed to, subscribes to the
MaybeSource
instance and
emits
onSuccess
as a single item or forwards any
onComplete
or
onError
signal.
- fromMaybe(MaybeSource<T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
instance that when subscribed to, subscribes to the
MaybeSource
instance and
emits
onSuccess
as a single item or forwards any
onComplete
or
onError
signal.
- fromMaybe(MaybeSource<T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
instance that when subscribed to, subscribes to the
MaybeSource
instance and
emits
onSuccess
as a single item, turns an
onComplete
into
NoSuchElementException
error signal or
forwards the
onError
signal.
- fromMaybe(MaybeSource<T>, T) - Static method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
instance that when subscribed to, subscribes to the
MaybeSource
instance and
emits
onSuccess
as a single item, emits the
defaultItem
for an
onComplete
signal or
forwards the
onError
signal.
- fromObservable(ObservableSource<T>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that subscribes to the given
ObservableSource
, ignores all values and
emits only the terminal event.
- fromObservable(ObservableSource<T>, BackpressureStrategy) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Converts the given
ObservableSource
into a
Flowable
by applying the specified backpressure strategy.
- fromObservable(ObservableSource<T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Wraps an
ObservableSource
into a
Maybe
and emits the very first item
or completes if the source is empty.
- fromObservable(ObservableSource<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Wraps a specific
ObservableSource
into a
Single
and signals its single element or error.
- fromOptional(Optional<T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
- fromOptional(Optional<T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- fromOptional(Optional<T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
- fromPublisher(Publisher<T>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that subscribes to the given
Publisher
, ignores all values and
emits only the terminal event.
- fromPublisher(Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Converts an arbitrary
Reactive Streams Publisher
into a
Flowable
if not already a
Flowable
.
- fromPublisher(Publisher<T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Wraps a
Publisher
into a
Maybe
and emits the very first item
or completes if the source is empty.
- fromPublisher(Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Converts an arbitrary
Reactive Streams Publisher
into an
Observable
.
- fromPublisher(Publisher<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Wraps a specific
Publisher
into a
Single
and signals its single element or error.
- fromRunnable(Runnable) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that runs the given
Runnable
for each
CompletableObserver
and
emits either its unchecked exception or simply completes.
- fromRunnable(Runnable) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
instance that runs the given
Runnable
for each
Subscriber
and
emits either its unchecked exception or simply completes.
- fromRunnable(Runnable) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
instance that runs the given
Runnable
for each
MaybeObserver
and
emits either its unchecked exception or simply completes.
- fromRunnable(Runnable) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
instance that runs the given
Runnable
for each
Observer
and
emits either its unchecked exception or simply completes.
- fromRunnable(Runnable) - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Construct a
Disposable
by wrapping a
Runnable
that is
executed exactly once when the
Disposable
is disposed.
- fromSingle(SingleSource<T>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that when subscribed to, subscribes to the
SingleSource
instance and
emits a completion event if the single emits
onSuccess
or forwards any
onError
events.
- fromSingle(SingleSource<T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
instance that when subscribed to, subscribes to the
SingleSource
instance and
emits
onSuccess
as a single item or forwards the
onError
signal.
- fromSingle(SingleSource<T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
- fromSingle(SingleSource<T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
instance that when subscribed to, subscribes to the
SingleSource
instance and
emits
onSuccess
as a single item or forwards the
onError
signal.
- fromStream(Stream<T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Converts a
Stream
into a finite
Flowable
and emits its items in the sequence.
- fromStream(Stream<T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Converts a
Stream
into a finite
Observable
and emits its items in the sequence.
- fromSubscription(Subscription) - Static method in interface io.reactivex.rxjava3.disposables.Disposable
-
Construct a
Disposable
by wrapping a
Subscription
that is
cancelled exactly once when the
Disposable
is disposed.
- fromSupplier(Supplier<?>) - Static method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which when subscribed, executes the
Supplier
function, ignores its
normal result and emits
onError
or
onComplete
only.
- fromSupplier(Supplier<? extends T>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that, when a
Subscriber
subscribes to it, invokes a supplier function you specify and then
emits the value returned from that function.
- fromSupplier(Supplier<? extends T>) - Static method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Maybe
that invokes the given
Supplier
for each individual
MaybeObserver
that
subscribes and emits the resulting non-
null
item via
onSuccess
while
considering a
null
result from the
Supplier
as indication for valueless completion
via
onComplete
.
- fromSupplier(Supplier<? extends T>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that, when an observer subscribes to it, invokes a supplier function you specify and then
emits the value returned from that function.
- fromSupplier(Supplier<? extends T>) - Static method in class io.reactivex.rxjava3.core.Single
-
Returns a
Single
that invokes passed supplier and emits its result
for each individual
SingleObserver
that subscribes.
- Function<T,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface that takes a value and returns another value, possibly with a
different type and allows throwing a checked exception.
- Function3<T1,T2,T3,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- Function4<T1,T2,T3,T4,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- Function5<T1,T2,T3,T4,T5,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- Function6<T1,T2,T3,T4,T5,T6,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- Function7<T1,T2,T3,T4,T5,T6,T7,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- Function8<T1,T2,T3,T4,T5,T6,T7,T8,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that computes a value based on multiple input values.
- generate(Consumer<Emitter<T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a cold, synchronous, stateless and backpressure-aware generator of values.
- generate(Supplier<S>, BiConsumer<S, Emitter<T>>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
- generate(Supplier<S>, BiConsumer<S, Emitter<T>>, Consumer<? super S>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
- generate(Supplier<S>, BiFunction<S, Emitter<T>, S>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
- generate(Supplier<S>, BiFunction<S, Emitter<T>, S>, Consumer<? super S>) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
- generate(Consumer<Emitter<T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns a cold, synchronous and stateless generator of values.
- generate(Supplier<S>, BiConsumer<S, Emitter<T>>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns a cold, synchronous and stateful generator of values.
- generate(Supplier<S>, BiConsumer<S, Emitter<T>>, Consumer<? super S>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns a cold, synchronous and stateful generator of values.
- generate(Supplier<S>, BiFunction<S, Emitter<T>, S>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns a cold, synchronous and stateful generator of values.
- generate(Supplier<S>, BiFunction<S, Emitter<T>, S>, Consumer<? super S>) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns a cold, synchronous and stateful generator of values.
- get() - Method in class io.reactivex.rxjava3.disposables.SerialDisposable
-
Returns the currently contained Disposable or null if this container is empty.
- get() - Method in interface io.reactivex.rxjava3.functions.Supplier
-
Produces a value or throws an exception.
- get() - Method in interface io.reactivex.rxjava3.operators.ScalarSupplier
-
- getAsBoolean() - Method in interface io.reactivex.rxjava3.functions.BooleanSupplier
-
Returns a boolean value.
- getCause() - Method in exception io.reactivex.rxjava3.exceptions.CompositeException
-
- getComputationSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getError() - Method in class io.reactivex.rxjava3.core.Notification
-
Returns the container
Throwable
error if this notification is an
onError
signal, null otherwise.
- getErrorHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the a hook consumer.
- getExceptions() - Method in exception io.reactivex.rxjava3.exceptions.CompositeException
-
Retrieves the list of exceptions that make up the CompositeException
.
- getInitComputationSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getInitIoSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getInitNewThreadSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getInitSingleSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getIoSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getKey() - Method in class io.reactivex.rxjava3.flowables.GroupedFlowable
-
Returns the key that identifies the group of items emitted by this GroupedFlowable
.
- getKey() - Method in class io.reactivex.rxjava3.observables.GroupedObservable
-
Returns the key that identifies the group of items emitted by this GroupedObservable
.
- getMessage() - Method in exception io.reactivex.rxjava3.exceptions.CompositeException
-
- getNewThreadSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnBeforeBlocking() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current blocking handler or null if no custom handler
is set.
- getOnCompletableAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnCompletableSubscribe() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnConnectableFlowableAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnConnectableObservableAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnFlowableAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnFlowableSubscribe() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnMaybeAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnMaybeSubscribe() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnObservableAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnObservableSubscribe() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnParallelAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnParallelSubscribe() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnSingleAssembly() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getOnSingleSubscribe() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getScheduleHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getSingleSchedulerHandler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns the current hook function.
- getThrowable() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- getThrowable() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- getThrowable() - Method in class io.reactivex.rxjava3.processors.FlowableProcessor
-
Returns the error that caused the FlowableProcessor to terminate or null if the FlowableProcessor
hasn't terminated yet.
- getThrowable() - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- getThrowable() - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- getThrowable() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- getThrowable() - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
Returns the terminal error if this CompletableSubject has been terminated with an error, null otherwise.
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Returns the terminal error if this MaybeSubject has been terminated with an error, null otherwise.
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
Returns the terminal error if this SingleSubject has been terminated with an error, null otherwise.
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.Subject
-
Returns the error that caused the Subject to terminate or null if the Subject
hasn't terminated yet.
- getThrowable() - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- getValue() - Method in class io.reactivex.rxjava3.core.Notification
-
Returns the contained value if this notification is an onNext
signal, null otherwise.
- getValue() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
Returns a single value this processor currently has or null if no such value exists.
- getValue() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
Returns a single value the BehaviorProcessor currently has or null if no such value exists.
- getValue() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Returns the latest value this processor has or null if no such value exists.
- getValue() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
Returns a single value the Subject currently has or null if no such value exists.
- getValue() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
Returns a single value the Subject currently has or null if no such value exists.
- getValue() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Returns the success value if this MaybeSubject was terminated with a success value.
- getValue() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Returns a single value the Subject currently has or null if no such value exists.
- getValue() - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
Returns the success value if this SingleSubject was terminated with a success value.
- getValues() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Returns an Object array containing snapshot all values of this processor.
- getValues(T[]) - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Returns a typed array containing a snapshot of all values of this processor.
- getValues() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Returns an Object array containing snapshot all values of the Subject.
- getValues(T[]) - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Returns a typed array containing a snapshot of all values of the Subject.
- getWrappedRunnable() - Method in interface io.reactivex.rxjava3.schedulers.SchedulerRunnableIntrospection
-
Returns the wrapped action.
- groupBy(Function<? super T, ? extends K>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Groups the items emitted by the current
Flowable
according to a specified criterion, and emits these
grouped items as
GroupedFlowable
s.
- groupBy(Function<? super T, ? extends K>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Groups the items emitted by the current
Flowable
according to a specified criterion, and emits these
grouped items as
GroupedFlowable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Groups the items emitted by the current
Flowable
according to a specified criterion, and emits these
grouped items as
GroupedFlowable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Groups the items emitted by the current
Flowable
according to a specified criterion, and emits these
grouped items as
GroupedFlowable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Groups the items emitted by the current
Flowable
according to a specified criterion, and emits these
grouped items as
GroupedFlowable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, boolean, int, Function<? super Consumer<Object>, ? extends Map<K, Object>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Groups the items emitted by the current
Flowable
according to a specified criterion, and emits these
grouped items as
GroupedFlowable
s.
- groupBy(Function<? super T, ? extends K>) - Method in class io.reactivex.rxjava3.core.Observable
-
Groups the items emitted by the current
Observable
according to a specified criterion, and emits these
grouped items as
GroupedObservable
s.
- groupBy(Function<? super T, ? extends K>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Groups the items emitted by the current
Observable
according to a specified criterion, and emits these
grouped items as
GroupedObservable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in class io.reactivex.rxjava3.core.Observable
-
Groups the items emitted by the current
Observable
according to a specified criterion, and emits these
grouped items as
GroupedObservable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Groups the items emitted by the current
Observable
according to a specified criterion, and emits these
grouped items as
GroupedObservable
s.
- groupBy(Function<? super T, ? extends K>, Function<? super T, ? extends V>, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Groups the items emitted by the current
Observable
according to a specified criterion, and emits these
grouped items as
GroupedObservable
s.
- GroupedFlowable<K,T> - Class in io.reactivex.rxjava3.flowables
-
- GroupedFlowable(K) - Constructor for class io.reactivex.rxjava3.flowables.GroupedFlowable
-
Constructs a GroupedFlowable with the given key.
- GroupedObservable<K,T> - Class in io.reactivex.rxjava3.observables
-
- GroupedObservable(K) - Constructor for class io.reactivex.rxjava3.observables.GroupedObservable
-
Constructs a GroupedObservable with the given key.
- groupJoin(Publisher<? extends TRight>, Function<? super T, ? extends Publisher<TLeftEnd>>, Function<? super TRight, ? extends Publisher<TRightEnd>>, BiFunction<? super T, ? super Flowable<TRight>, ? extends R>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that correlates two
Publisher
s when they overlap in time and groups the results.
- groupJoin(ObservableSource<? extends TRight>, Function<? super T, ? extends ObservableSource<TLeftEnd>>, Function<? super TRight, ? extends ObservableSource<TRightEnd>>, BiFunction<? super T, ? super Observable<TRight>, ? extends R>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that correlates two
ObservableSource
s when they overlap in time and groups the results.
- hasComplete() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- hasComplete() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- hasComplete() - Method in class io.reactivex.rxjava3.processors.FlowableProcessor
-
Returns true if the FlowableProcessor has reached a terminal state through a complete event.
- hasComplete() - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- hasComplete() - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- hasComplete() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- hasComplete() - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
Returns true if this CompletableSubject has been completed.
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Returns true if this MaybeSubject has been completed.
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.Subject
-
Returns true if the subject has reached a terminal state through a complete event.
- hasComplete() - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- hasCustomOnError() - Method in interface io.reactivex.rxjava3.observers.LambdaConsumerIntrospection
-
Returns true
or false
if a custom onError
consumer has been provided.
- hashCode() - Method in class io.reactivex.rxjava3.core.Notification
-
- hashCode() - Method in class io.reactivex.rxjava3.schedulers.Timed
-
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
Returns true if this CompletableSubject has observers.
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Returns true if this MaybeSubject has observers.
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
Returns true if this SingleSubject has observers.
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.Subject
-
Returns true if the subject has any Observers.
- hasObservers() - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.FlowableProcessor
-
Returns true if the FlowableProcessor has subscribers.
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- hasSubscribers() - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- hasSubscription() - Method in class io.reactivex.rxjava3.observers.TestObserver
-
Returns true if this TestObserver
received a subscription.
- hasSubscription() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.FlowableProcessor
-
Returns true if the FlowableProcessor has reached a terminal state through an error event.
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- hasThrowable() - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
Returns true if this CompletableSubject has been terminated with an error.
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Returns true if this MaybeSubject has been terminated with an error.
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
Returns true if this SingleSubject has been terminated with an error.
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.Subject
-
Returns true if the subject has reached a terminal state through an error event.
- hasThrowable() - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- hasValue() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
Returns true if this processor has any value.
- hasValue() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
Returns true if the BehaviorProcessor has any value.
- hasValue() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
Returns true if this processor has any value.
- hasValue() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
Returns true if the subject has any value.
- hasValue() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
Returns true if the subject has any value.
- hasValue() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
Returns true if this MaybeSubject was terminated with a success value.
- hasValue() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
Returns true if the subject has any value.
- hasValue() - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
Returns true if this SingleSubject was terminated with a success value.
- hide() - Method in class io.reactivex.rxjava3.core.Completable
-
Hides the identity of this
Completable
and its
Disposable
.
- hide() - Method in class io.reactivex.rxjava3.core.Flowable
-
- hide() - Method in class io.reactivex.rxjava3.core.Maybe
-
Hides the identity of this
Maybe
and its
Disposable
.
- hide() - Method in class io.reactivex.rxjava3.core.Observable
-
Hides the identity of the current
Observable
and its
Disposable
.
- hide() - Method in class io.reactivex.rxjava3.core.Single
-
Hides the identity of the current
Single
, including the
Disposable
that is sent
to the downstream via
onSubscribe()
.
- ignoreElement() - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Completable
that ignores the item emitted by the current
Maybe
and only calls
onComplete
or
onError
.
- ignoreElement() - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Completable
that ignores the success value of this
Single
and signals
onComplete
instead.
- ignoreElements() - Method in class io.reactivex.rxjava3.core.Flowable
-
Ignores all items emitted by the current Flowable
and only calls onComplete
or onError
.
- ignoreElements() - Method in class io.reactivex.rxjava3.core.Observable
-
Ignores all items emitted by the current Observable
and only calls onComplete
or onError
.
- initComputationScheduler(Supplier<Scheduler>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- initIoScheduler(Supplier<Scheduler>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- initNewThreadScheduler(Supplier<Scheduler>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- initSingleScheduler(Supplier<Scheduler>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- interval(long, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits a 0L
after the initialDelay
and ever-increasing numbers
after each period
of time thereafter.
- interval(long, long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits a
0L
after the
initialDelay
and ever-increasing numbers
after each
period
of time thereafter, on a specified
Scheduler
.
- interval(long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
that emits a sequential number every specified interval of time.
- interval(long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Flowable
that emits a sequential number every specified interval of time, on a
specified
Scheduler
.
- interval(long, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits a 0L
after the initialDelay
and ever increasing numbers
after each period
of time thereafter.
- interval(long, long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits a
0L
after the
initialDelay
and ever increasing numbers
after each
period
of time thereafter, on a specified
Scheduler
.
- interval(long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
that emits a sequential number every specified interval of time.
- interval(long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
that emits a sequential number every specified interval of time, on a
specified
Scheduler
.
- intervalRange(long, long, long, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Signals a range of long values, the first after some initial delay and the rest periodically after.
- intervalRange(long, long, long, long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.core.Flowable
-
Signals a range of long values, the first after some initial delay and the rest periodically after.
- intervalRange(long, long, long, long, TimeUnit) - Static method in class io.reactivex.rxjava3.core.Observable
-
Signals a range of long values, the first after some initial delay and the rest periodically after.
- intervalRange(long, long, long, long, TimeUnit, Scheduler) - Static method in class io.reactivex.rxjava3.core.Observable
-
Signals a range of long values, the first after some initial delay and the rest periodically after.
- IntFunction<T> - Interface in io.reactivex.rxjava3.functions
-
A functional interface (callback) that takes a primitive value and return value of type T.
- IO - Static variable in annotation type io.reactivex.rxjava3.annotations.SchedulerSupport
-
The operator/class runs on RxJava's
I/O scheduler or takes
timing information from it.
- io() - Static method in class io.reactivex.rxjava3.schedulers.Schedulers
-
Returns a default, shared
Scheduler
instance intended for IO-bound work.
- io.reactivex.rxjava3.annotations - package io.reactivex.rxjava3.annotations
-
- io.reactivex.rxjava3.core - package io.reactivex.rxjava3.core
-
- io.reactivex.rxjava3.disposables - package io.reactivex.rxjava3.disposables
-
Default implementations for
Disposable
-based resource management
(
Disposable
container types) and utility classes to construct
Disposables
from callbacks and other types.
- io.reactivex.rxjava3.exceptions - package io.reactivex.rxjava3.exceptions
-
- io.reactivex.rxjava3.flowables - package io.reactivex.rxjava3.flowables
-
- io.reactivex.rxjava3.functions - package io.reactivex.rxjava3.functions
-
Functional interfaces of functions and actions of arity 0 to 9 and related
utility classes.
- io.reactivex.rxjava3.observables - package io.reactivex.rxjava3.observables
-
- io.reactivex.rxjava3.observers - package io.reactivex.rxjava3.observers
-
Default wrappers and implementations for observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver
that allows unit testing
Observable
-,
Single
-,
Maybe
- and
Completable
-based flows.
- io.reactivex.rxjava3.operators - package io.reactivex.rxjava3.operators
-
Classes and interfaces for writing advanced operators within and outside RxJava.
- io.reactivex.rxjava3.parallel - package io.reactivex.rxjava3.parallel
-
- io.reactivex.rxjava3.plugins - package io.reactivex.rxjava3.plugins
-
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.
- io.reactivex.rxjava3.processors - package io.reactivex.rxjava3.processors
-
Classes representing so-called hot backpressure-aware sources, aka
processors,
that implement the
FlowableProcessor
class,
the Reactive Streams
Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams
Publisher
.
- io.reactivex.rxjava3.schedulers - package io.reactivex.rxjava3.schedulers
-
Contains notably the factory class of
Schedulers
providing methods for
retrieving the standard scheduler instances, the
TestScheduler
for testing flows
with scheduling in a controlled manner and the class
Timed
that can hold
a value and a timestamp associated with it.
- io.reactivex.rxjava3.subjects - package io.reactivex.rxjava3.subjects
-
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
- io.reactivex.rxjava3.subscribers - package io.reactivex.rxjava3.subscribers
-
- isCancelled() - Method in interface io.reactivex.rxjava3.core.FlowableEmitter
-
- isCancelled() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
Returns true if this TestSubscriber
has been cancelled.
- isDisposed() - Method in interface io.reactivex.rxjava3.core.CompletableEmitter
-
- isDisposed() - Method in interface io.reactivex.rxjava3.core.MaybeEmitter
-
- isDisposed() - Method in interface io.reactivex.rxjava3.core.ObservableEmitter
-
- isDisposed() - Method in interface io.reactivex.rxjava3.core.SingleEmitter
-
- isDisposed() - Method in class io.reactivex.rxjava3.disposables.CompositeDisposable
-
- isDisposed() - Method in interface io.reactivex.rxjava3.disposables.Disposable
-
Returns true if this resource has been disposed.
- isDisposed() - Method in class io.reactivex.rxjava3.disposables.SerialDisposable
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.BaseTestConsumer
-
Returns true if this test consumer was cancelled/disposed.
- isDisposed() - Method in class io.reactivex.rxjava3.observers.DisposableCompletableObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.DisposableMaybeObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.DisposableObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.DisposableSingleObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.ResourceCompletableObserver
-
Returns true if this ResourceCompletableObserver
has been disposed/cancelled.
- isDisposed() - Method in class io.reactivex.rxjava3.observers.ResourceMaybeObserver
-
Returns true if this ResourceMaybeObserver
has been disposed/cancelled.
- isDisposed() - Method in class io.reactivex.rxjava3.observers.ResourceObserver
-
Returns true if this ResourceObserver
has been disposed/cancelled.
- isDisposed() - Method in class io.reactivex.rxjava3.observers.ResourceSingleObserver
-
Returns true if this ResourceSingleObserver
has been disposed/cancelled.
- isDisposed() - Method in class io.reactivex.rxjava3.observers.SafeObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.SerializedObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- isDisposed() - Method in class io.reactivex.rxjava3.subscribers.DisposableSubscriber
-
- isDisposed() - Method in class io.reactivex.rxjava3.subscribers.ResourceSubscriber
-
Returns true if this ResourceSubscriber
has been disposed/cancelled.
- isDisposed() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- isEmpty() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a
Single
that emits
true
if the current
Flowable
is empty, otherwise
false
.
- isEmpty() - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a
Single
that emits
true
if the current
Maybe
is empty, otherwise
false
.
- isEmpty() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns a
Single
that emits
true
if the current
Observable
is empty, otherwise
false
.
- isEmpty() - Method in interface io.reactivex.rxjava3.operators.SimpleQueue
-
Returns true if the queue is empty.
- isEmpty() - Method in class io.reactivex.rxjava3.operators.SpscArrayQueue
-
- isEmpty() - Method in class io.reactivex.rxjava3.operators.SpscLinkedArrayQueue
-
- isFailOnNonBlockingScheduler() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns true if the blockingX operators fail
with an IllegalStateException on a non-blocking scheduler
such as computation or single.
- isLockdown() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Returns true if the plugins were locked down.
- isOnComplete() - Method in class io.reactivex.rxjava3.core.Notification
-
Returns true if this notification is an onComplete
signal.
- isOnError() - Method in class io.reactivex.rxjava3.core.Notification
-
- isOnNext() - Method in class io.reactivex.rxjava3.core.Notification
-
- Observable<T> - Class in io.reactivex.rxjava3.core
-
The Observable
class is the non-backpressured, optionally multi-valued base reactive class that
offers factory methods, intermediate operators and the ability to consume synchronous
and/or asynchronous reactive dataflows.
- Observable() - Constructor for class io.reactivex.rxjava3.core.Observable
-
- ObservableConverter<T,R> - Interface in io.reactivex.rxjava3.core
-
- ObservableEmitter<T> - Interface in io.reactivex.rxjava3.core
-
Abstraction over an RxJava
Observer
that allows associating
a resource with it.
- ObservableOnSubscribe<T> - Interface in io.reactivex.rxjava3.core
-
A functional interface that has a
subscribe()
method that receives
an
ObservableEmitter
instance that allows pushing
events in a cancellation-safe manner.
- ObservableOperator<Downstream,Upstream> - Interface in io.reactivex.rxjava3.core
-
Interface to map/wrap a downstream
Observer
to an upstream
Observer
.
- ObservableSource<T> - Interface in io.reactivex.rxjava3.core
-
Represents a basic, non-backpressured
Observable
source base interface,
consumable via an
Observer
.
- ObservableTransformer<Upstream,Downstream> - Interface in io.reactivex.rxjava3.core
-
- observeOn(Scheduler) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
which emits the terminal events from the thread of the specified
Scheduler
.
- observeOn(Scheduler) - Method in class io.reactivex.rxjava3.core.Flowable
-
Signals the items and terminal signals of the current
Flowable
on the specified
Scheduler
,
asynchronously with a bounded buffer of
Flowable.bufferSize()
slots.
- observeOn(Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Signals the items and terminal signals of the current
Flowable
on the specified
Scheduler
,
asynchronously with a bounded buffer and optionally delays
onError
notifications.
- observeOn(Scheduler, boolean, int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Signals the items and terminal signals of the current
Flowable
on the specified
Scheduler
,
asynchronously with a bounded buffer of configurable size and optionally delays
onError
notifications.
- observeOn(Scheduler) - Method in class io.reactivex.rxjava3.core.Maybe
-
Wraps a
Maybe
to emit its item (or notify of its error) on a specified
Scheduler
,
asynchronously.
- observeOn(Scheduler) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
to perform the current
Observable
's emissions and notifications on a specified
Scheduler
,
asynchronously with an unbounded buffer with
Flowable.bufferSize()
"island size".
- observeOn(Scheduler, boolean) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
to perform the current
Observable
's emissions and notifications on a specified
Scheduler
,
asynchronously with an unbounded buffer with
Flowable.bufferSize()
"island size" and optionally delays
onError
notifications.
- observeOn(Scheduler, boolean, int) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an
Observable
to perform the current
Observable
's emissions and notifications on a specified
Scheduler
,
asynchronously with an unbounded buffer of configurable "island size" and optionally delays
onError
notifications.
- observeOn(Scheduler) - Method in class io.reactivex.rxjava3.core.Single
-
Signals the success item or the terminal signals of the current
Single
on the specified
Scheduler
,
asynchronously.
- Observer<T> - Interface in io.reactivex.rxjava3.core
-
Provides a mechanism for receiving push-based notifications.
- offer(T) - Method in interface io.reactivex.rxjava3.operators.SimpleQueue
-
Atomically enqueue a single value.
- offer(T, T) - Method in interface io.reactivex.rxjava3.operators.SimpleQueue
-
Atomically enqueue two values.
- offer(E) - Method in class io.reactivex.rxjava3.operators.SpscArrayQueue
-
- offer(E, E) - Method in class io.reactivex.rxjava3.operators.SpscArrayQueue
-
- offer(T) - Method in class io.reactivex.rxjava3.operators.SpscLinkedArrayQueue
-
Atomically enqueue a single value.
- offer(T, T) - Method in class io.reactivex.rxjava3.operators.SpscLinkedArrayQueue
-
Offer two elements at the same time.
- offer(T) - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
Tries to emit the item to all currently subscribed
Subscriber
s if all of them
has requested some value, returns
false
otherwise.
- offer(T) - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
Tries to offer an item into the internal queue and returns false
if the queue is full.
- offer(T) - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
Tries to emit the item to all currently subscribed
Subscriber
s if all of them
has requested some value, returns
false
otherwise.
- ofType(Class<U>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Filters the items emitted by the current Flowable
, only emitting those of the specified type.
- ofType(Class<U>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Filters the items emitted by the current
Maybe
, only emitting its success value if that
is an instance of the supplied
Class
.
- ofType(Class<U>) - Method in class io.reactivex.rxjava3.core.Observable
-
Filters the items emitted by the current Observable
, only emitting those of the specified type.
- ofType(Class<U>) - Method in class io.reactivex.rxjava3.core.Single
-
Filters the items emitted by the current
Single
, only emitting its success value if that
is an instance of the supplied
Class
.
- onAssembly(Maybe<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(Flowable<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(ConnectableFlowable<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(Observable<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(ConnectableObservable<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(Single<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(Completable) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onAssembly(ParallelFlowable<T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onBackpressureBuffer() - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
- onBackpressureBuffer(boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, optionally delaying an error until all buffered items have been consumed.
- onBackpressureBuffer(int) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an limited number of items from the current
Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, however, the resulting
Flowable
will signal a
MissingBackpressureException
via
onError
as soon as the buffer's capacity is exceeded, dropping all undelivered
items, and canceling the flow.
- onBackpressureBuffer(int, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an limited number of items from the current
Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, however, the resulting
Flowable
will signal a
MissingBackpressureException
via
onError
as soon as the buffer's capacity is exceeded, dropping all undelivered
items, and canceling the flow.
- onBackpressureBuffer(int, boolean, boolean) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an optionally unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
- onBackpressureBuffer(int, boolean, boolean, Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an optionally unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
- onBackpressureBuffer(int, boolean, boolean, Action, Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an optionally unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
- onBackpressureBuffer(int, Action) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an limited number of items from the current
Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, however, the resulting
Flowable
will signal a
MissingBackpressureException
via
onError
as soon as the buffer's capacity is exceeded, dropping all undelivered
items, canceling the flow and calling the
onOverflow
action.
- onBackpressureBuffer(long, Action, BackpressureOverflowStrategy) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an optionally unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
- onBackpressureBuffer(long, Action, BackpressureOverflowStrategy, Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Buffers an optionally unlimited number of items from the current Flowable
and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
- onBackpressureDrop() - Method in class io.reactivex.rxjava3.core.Flowable
-
Drops items from the current
Flowable
if the downstream is not ready to receive new items (indicated
by a lack of
Subscription.request(long)
calls from it).
- onBackpressureDrop(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Drops items from the current
Flowable
if the downstream is not ready to receive new items (indicated
by a lack of
Subscription.request(long)
calls from it) and calls the given
Consumer
with such
dropped items.
- onBackpressureLatest() - Method in class io.reactivex.rxjava3.core.Flowable
-
Drops all but the latest item emitted by the current
Flowable
if the downstream is not ready to receive
new items (indicated by a lack of
Subscription.request(long)
calls from it) and emits this latest
item when the downstream becomes ready.
- onBackpressureLatest(Consumer<? super T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Drops all but the latest item emitted by the current
Flowable
if the downstream is not ready to receive
new items (indicated by a lack of
Subscription.request(long)
calls from it) and emits this latest
item when the downstream becomes ready.
- onBackpressureReduce(BiFunction<T, T, T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Reduces a sequence of two not emitted values via a function into a single value if the downstream is not ready to receive
new items (indicated by a lack of
Subscription.request(long)
calls from it) and emits this latest
item when the downstream becomes ready.
- onBackpressureReduce(Supplier<R>, BiFunction<R, ? super T, R>) - Method in class io.reactivex.rxjava3.core.Flowable
-
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.
- onBeforeBlocking() - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Called before an operator attempts a blocking operation
such as awaiting a condition or signal
and should return true to indicate the operator
should not block but throw an IllegalArgumentException.
- onComplete() - Method in interface io.reactivex.rxjava3.core.CompletableEmitter
-
Signal the completion.
- onComplete() - Method in interface io.reactivex.rxjava3.core.CompletableObserver
-
Called once the deferred computation completes normally.
- onComplete() - Method in interface io.reactivex.rxjava3.core.Emitter
-
Signal a completion.
- onComplete() - Method in interface io.reactivex.rxjava3.core.MaybeEmitter
-
Signal the completion.
- onComplete() - Method in interface io.reactivex.rxjava3.core.MaybeObserver
-
Called once the deferred computation completes normally.
- onComplete() - Method in interface io.reactivex.rxjava3.core.Observer
-
- onComplete() - Method in class io.reactivex.rxjava3.observers.SafeObserver
-
- onComplete() - Method in class io.reactivex.rxjava3.observers.SerializedObserver
-
- onComplete() - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- onComplete() - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- onComplete() - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- onComplete() - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- onComplete() - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- onComplete() - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- onComplete() - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- onComplete() - Method in class io.reactivex.rxjava3.subscribers.SafeSubscriber
-
- onComplete() - Method in class io.reactivex.rxjava3.subscribers.SerializedSubscriber
-
- onComplete() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- onComputationScheduler(Scheduler) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.CompletableEmitter
-
Signal an exception.
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.CompletableObserver
-
Called once if the deferred computation 'throws' an exception.
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.Emitter
-
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.MaybeEmitter
-
Signal an exception.
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.MaybeObserver
-
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.Observer
-
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.SingleEmitter
-
Signal an exception.
- onError(Throwable) - Method in interface io.reactivex.rxjava3.core.SingleObserver
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.observers.SafeObserver
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.observers.SerializedObserver
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- onError(Throwable) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Called when an undeliverable error occurs.
- onError(Throwable) - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subscribers.SafeSubscriber
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subscribers.SerializedSubscriber
-
- onError(Throwable) - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- onErrorComplete() - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that if this
Completable
emits an error, it will emit an
onComplete
and swallow the upstream
Throwable
.
- onErrorComplete(Predicate<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that if this
Completable
emits an error and the
Predicate
returns
true
, it will emit an
onComplete
and swallow the
Throwable
.
- onErrorComplete() - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
instance that if the current Flowable
emits an error, it will emit an onComplete
and swallow the throwable.
- onErrorComplete(Predicate<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Returns a Flowable
instance that if the current Flowable
emits an error and the predicate returns
true
, it will emit an onComplete
and swallow the throwable.
- onErrorComplete() - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
instance that if this Maybe
emits an error, it will emit an onComplete
and swallow the throwable.
- onErrorComplete(Predicate<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Returns a Maybe
instance that if this Maybe
emits an error and the predicate returns
true
, it will emit an onComplete
and swallow the throwable.
- onErrorComplete() - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
instance that if the current Observable
emits an error, it will emit an onComplete
and swallow the throwable.
- onErrorComplete(Predicate<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Observable
-
Returns an Observable
instance that if the current Observable
emits an error and the predicate returns
true
, it will emit an onComplete
and swallow the throwable.
- onErrorComplete() - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Maybe
instance that if the current
Single
emits an error, it will emit an
onComplete
and swallow the throwable.
- onErrorComplete(Predicate<? super Throwable>) - Method in class io.reactivex.rxjava3.core.Single
-
Returns a
Maybe
instance that if this
Single
emits an error and the predicate returns
true
, it will emit an
onComplete
and swallow the throwable.
- OnErrorNotImplementedException - Exception in io.reactivex.rxjava3.exceptions
-
Represents an exception used to signal to the RxJavaPlugins.onError()
that a
callback-based subscribe() method on a base reactive type didn't specify
an onError handler.
- OnErrorNotImplementedException(String, Throwable) - Constructor for exception io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException
-
Customizes the Throwable
with a custom message and wraps it before it
is signalled to the RxJavaPlugins.onError()
handler as OnErrorNotImplementedException
.
- OnErrorNotImplementedException(Throwable) - Constructor for exception io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException
-
Wraps the Throwable
before it
is signalled to the RxJavaPlugins.onError()
handler as OnErrorNotImplementedException
.
- onErrorResumeNext(Function<? super Throwable, ? extends CompletableSource>) - Method in class io.reactivex.rxjava3.core.Completable
-
Returns a
Completable
instance that when encounters an error from this
Completable
, calls the
specified
mapper
Function
that returns a
CompletableSource
instance for it and resumes the
execution with it.
- onErrorResumeNext(Function<? super Throwable, ? extends Publisher<? extends T>>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Resumes the flow with a
Publisher
returned for the failure
Throwable
of the current
Flowable
by a
function instead of signaling the error via
onError
.
- onErrorResumeNext(Function<? super Throwable, ? extends MaybeSource<? extends T>>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Resumes the flow with a
MaybeSource
returned for the failure
Throwable
of the current
Maybe
by a
function instead of signaling the error via
onError
.
- onErrorResumeNext(Function<? super Throwable, ? extends ObservableSource<? extends T>>) - Method in class io.reactivex.rxjava3.core.Observable
-
Resumes the flow with an
ObservableSource
returned for the failure
Throwable
of the current
Observable
by a
function instead of signaling the error via
onError
.
- onErrorResumeNext(Function<? super Throwable, ? extends SingleSource<? extends T>>) - Method in class io.reactivex.rxjava3.core.Single
-
Resumes the flow with a
SingleSource
returned for the failure
Throwable
of the current
Single
by a
function instead of signaling the error via
onError
.
- onErrorResumeWith(CompletableSource) - Method in class io.reactivex.rxjava3.core.Completable
-
Resumes the flow with the given
CompletableSource
when the current
Completable
fails instead of
signaling the error via
onError
.
- onErrorResumeWith(Publisher<? extends T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Resumes the flow with the given
Publisher
when the current
Flowable
fails instead of
signaling the error via
onError
.
- onErrorResumeWith(MaybeSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Resumes the flow with the given
MaybeSource
when the current
Maybe
fails instead of
signaling the error via
onError
.
- onErrorResumeWith(ObservableSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Resumes the flow with the given
ObservableSource
when the current
Observable
fails instead of
signaling the error via
onError
.
- onErrorResumeWith(SingleSource<? extends T>) - Method in class io.reactivex.rxjava3.core.Single
-
Resumes the flow with the given
SingleSource
when the current
Single
fails instead of
signaling the error via
onError
.
- onErrorReturn(Function<? super Throwable, ? extends T>) - Method in class io.reactivex.rxjava3.core.Completable
-
Ends the flow with a success item returned by a function for the
Throwable
error signaled by the current
Completable
instead of signaling the error via
onError
.
- onErrorReturn(Function<? super Throwable, ? extends T>) - Method in class io.reactivex.rxjava3.core.Flowable
-
Ends the flow with a last item returned by a function for the
Throwable
error signaled by the current
Flowable
instead of signaling the error via
onError
.
- onErrorReturn(Function<? super Throwable, ? extends T>) - Method in class io.reactivex.rxjava3.core.Maybe
-
Ends the flow with a success item returned by a function for the
Throwable
error signaled by the current
Maybe
instead of signaling the error via
onError
.
- onErrorReturn(Function<? super Throwable, ? extends T>) - Method in class io.reactivex.rxjava3.core.Observable
-
Ends the flow with a last item returned by a function for the
Throwable
error signaled by the current
Observable
instead of signaling the error via
onError
.
- onErrorReturn(Function<Throwable, ? extends T>) - Method in class io.reactivex.rxjava3.core.Single
-
Ends the flow with a success item returned by a function for the
Throwable
error signaled by the current
Single
instead of signaling the error via
onError
.
- onErrorReturnItem(T) - Method in class io.reactivex.rxjava3.core.Completable
-
Ends the flow with the given success item when the current Completable
fails instead of signaling the error via onError
.
- onErrorReturnItem(T) - Method in class io.reactivex.rxjava3.core.Flowable
-
Ends the flow with the given last item when the current Flowable
fails instead of signaling the error via onError
.
- onErrorReturnItem(T) - Method in class io.reactivex.rxjava3.core.Maybe
-
Ends the flow with the given success item when the current Maybe
fails instead of signaling the error via onError
.
- onErrorReturnItem(T) - Method in class io.reactivex.rxjava3.core.Observable
-
Ends the flow with the given last item when the current Observable
fails instead of signaling the error via onError
.
- onErrorReturnItem(T) - Method in class io.reactivex.rxjava3.core.Single
-
Signals the specified value as success in case the current Single
signals an error.
- onIoScheduler(Scheduler) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onNewThreadScheduler(Scheduler) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onNext(T) - Method in interface io.reactivex.rxjava3.core.Emitter
-
Signal a normal value.
- onNext(T) - Method in interface io.reactivex.rxjava3.core.Observer
-
Provides the
Observer
with a new item to observe.
- onNext(T) - Method in class io.reactivex.rxjava3.observers.SafeObserver
-
- onNext(T) - Method in class io.reactivex.rxjava3.observers.SerializedObserver
-
- onNext(T) - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- onNext(T) - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- onNext(T) - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- onNext(T) - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- onNext(T) - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- onNext(T) - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- onNext(T) - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- onNext(T) - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- onNext(T) - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- onNext(T) - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- onNext(T) - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- onNext(T) - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- onNext(T) - Method in class io.reactivex.rxjava3.subscribers.SafeSubscriber
-
- onNext(T) - Method in class io.reactivex.rxjava3.subscribers.SerializedSubscriber
-
- onNext(T) - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- onSchedule(Runnable) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Called when a task is scheduled.
- onSingleScheduler(Scheduler) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onStart() - Method in class io.reactivex.rxjava3.observers.DefaultObserver
-
Called once the subscription has been set on this observer; override this
to perform initialization.
- onStart() - Method in class io.reactivex.rxjava3.observers.DisposableCompletableObserver
-
- onStart() - Method in class io.reactivex.rxjava3.observers.DisposableMaybeObserver
-
- onStart() - Method in class io.reactivex.rxjava3.observers.DisposableObserver
-
Called once the single upstream Disposable is set via onSubscribe.
- onStart() - Method in class io.reactivex.rxjava3.observers.DisposableSingleObserver
-
- onStart() - Method in class io.reactivex.rxjava3.observers.ResourceCompletableObserver
-
Called once the upstream sets a
Disposable
on this
ResourceCompletableObserver
.
- onStart() - Method in class io.reactivex.rxjava3.observers.ResourceMaybeObserver
-
Called once the upstream sets a
Disposable
on this
ResourceMaybeObserver
.
- onStart() - Method in class io.reactivex.rxjava3.observers.ResourceObserver
-
Called once the upstream sets a
Disposable
on this
ResourceObserver
.
- onStart() - Method in class io.reactivex.rxjava3.observers.ResourceSingleObserver
-
Called once the upstream sets a
Disposable
on this
ResourceSingleObserver
.
- onStart() - Method in class io.reactivex.rxjava3.subscribers.DefaultSubscriber
-
Called once the subscription has been set on this observer; override this
to perform initialization or issue an initial request.
- onStart() - Method in class io.reactivex.rxjava3.subscribers.DisposableSubscriber
-
- onStart() - Method in class io.reactivex.rxjava3.subscribers.ResourceSubscriber
-
Called once the upstream sets a
Subscription
on this
ResourceSubscriber
.
- onStart() - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
Called after the onSubscribe is called and handled.
- onSubscribe(Disposable) - Method in interface io.reactivex.rxjava3.core.CompletableObserver
-
Called once by the
Completable
to set a
Disposable
on this instance which
then can be used to cancel the subscription at any time.
- onSubscribe(Subscription) - Method in interface io.reactivex.rxjava3.core.FlowableSubscriber
-
- onSubscribe(Disposable) - Method in interface io.reactivex.rxjava3.core.MaybeObserver
-
Provides the
MaybeObserver
with the means of cancelling (disposing) the
connection (channel) with the
Maybe
in both
synchronous (from within
onSubscribe(Disposable)
itself) and asynchronous manner.
- onSubscribe(Disposable) - Method in interface io.reactivex.rxjava3.core.Observer
-
- onSubscribe(Disposable) - Method in interface io.reactivex.rxjava3.core.SingleObserver
-
Provides the
SingleObserver
with the means of cancelling (disposing) the
connection (channel) with the Single in both
synchronous (from within
onSubscribe(Disposable)
itself) and asynchronous manner.
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.DefaultObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.DisposableCompletableObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.DisposableMaybeObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.DisposableObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.DisposableSingleObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceCompletableObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceMaybeObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.ResourceSingleObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.SafeObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.SerializedObserver
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- onSubscribe(Flowable<T>, Subscriber<? super T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onSubscribe(Observable<T>, Observer<? super T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onSubscribe(Single<T>, SingleObserver<? super T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onSubscribe(Completable, CompletableObserver) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onSubscribe(Maybe<T>, MaybeObserver<? super T>) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onSubscribe(ParallelFlowable<T>, Subscriber<? super T>[]) - Static method in class io.reactivex.rxjava3.plugins.RxJavaPlugins
-
Calls the associated hook function.
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.processors.AsyncProcessor
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.processors.BehaviorProcessor
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.processors.MulticastProcessor
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.processors.PublishProcessor
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.processors.ReplayProcessor
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.processors.UnicastProcessor
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.AsyncSubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.BehaviorSubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.CompletableSubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.PublishSubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.ReplaySubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
- onSubscribe(Disposable) - Method in class io.reactivex.rxjava3.subjects.UnicastSubject
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.subscribers.DefaultSubscriber
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.subscribers.DisposableSubscriber
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.subscribers.ResourceSubscriber
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.subscribers.SafeSubscriber
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.subscribers.SerializedSubscriber
-
- onSubscribe(Subscription) - Method in class io.reactivex.rxjava3.subscribers.TestSubscriber
-
- onSuccess(T) - Method in interface io.reactivex.rxjava3.core.MaybeEmitter
-
Signal a success value.
- onSuccess(T) - Method in interface io.reactivex.rxjava3.core.MaybeObserver
-
Notifies the
MaybeObserver
with one item and that the
Maybe
has finished sending
push-based notifications.
- onSuccess(T) - Method in interface io.reactivex.rxjava3.core.SingleEmitter
-
Signal a success value.
- onSuccess(T) - Method in interface io.reactivex.rxjava3.core.SingleObserver
-
Notifies the
SingleObserver
with a single item and that the
Single
has finished sending
push-based notifications.
- onSuccess(T) - Method in class io.reactivex.rxjava3.observers.TestObserver
-
- onSuccess(T) - Method in class io.reactivex.rxjava3.subjects.MaybeSubject
-
- onSuccess(T) - Method in class io.reactivex.rxjava3.subjects.SingleSubject
-
- onTerminateDetach() - Method in class io.reactivex.rxjava3.core.Completable
-
Nulls out references to the upstream producer and downstream
CompletableObserver
if
the sequence is terminated or downstream calls
dispose()
.
- onTerminateDetach() - Method in class io.reactivex.rxjava3.core.Flowable
-
Nulls out references to the upstream producer and downstream
Subscriber
if
the sequence is terminated or downstream cancels.
- onTerminateDetach() - Method in class io.reactivex.rxjava3.core.Maybe
-
Nulls out references to the upstream producer and downstream
MaybeObserver
if
the sequence is terminated or downstream calls
dispose()
.
- onTerminateDetach() - Method in class io.reactivex.rxjava3.core.Observable
-
Nulls out references to the upstream producer and downstream
Observer
if
the sequence is terminated or downstream calls
dispose()
.
- onTerminateDetach() - Method in class io.reactivex.rxjava3.core.Single
-
Nulls out references to the upstream producer and downstream
SingleObserver
if
the sequence is terminated or downstream calls
dispose()
.