Returns a Completable which terminates as soon as one of the source Completables in the Iterable sequence
terminates (normally or with an error) and disposes all other Completables.
Returns a Completable which terminates as soon as one of the source Completables
terminates (normally or with an error) and disposes all other Completables.
Assert that this TestObserver/TestSubscriber received exactly one onNext value which is equal to
the given value with respect to Objects.equals(Object, Object).
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).
Returns a Flowable that automatically connects (at most once) to this ConnectableFlowable
when the specified number of Subscribers subscribe to it and calls the
specified callback with the Disposable associated with the established connection.
Returns an Observable that automatically connects (at most once) to this ConnectableObservable
when the specified number of Observers subscribe to it and calls the
specified callback with the Disposable associated with the established connection.
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.
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.
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.
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.
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.
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.
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).
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).
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.
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.
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.
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.
A functional interface (callback) that returns a boolean value.
BOUNDARY - Static variable in interface io.reactivex.rxjava3.operators.QueueFuseable
Used in binary or combination with the other constants as an input to QueueFuseable.requestFusion(int)
indicating that the SimpleQueue.poll() will be called behind an asynchronous boundary and thus
may change the non-trivial computation locations attached to the SimpleQueue.poll() chain of
fused operators.
Returns an Observable that emits non-overlapping buffered items from the current Observable each time the
specified boundary ObservableSource emits an item.
Returns an Observable that emits non-overlapping buffered items from the current Observable each time the
specified boundary ObservableSource emits an item.
Returns an Observable that emits non-overlapping buffered items from the current Observable each time the
specified boundary ObservableSource emits an item.
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.
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 SingleObservers.
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.
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.
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.
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.
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.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines two source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from either of the source Publishers, where this
aggregation is defined by a specified function.
Combines three source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines four source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines five source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines six source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines seven source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines eight source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines nine source Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the returned ObservableSources each time an item is received from any of the returned ObservableSources, where this
aggregation is defined by a specified function.
Combines an Iterable of source ObservableSources by emitting an item that aggregates the latest values of each of
the returned ObservableSources each time an item is received from any of the returned ObservableSources, where this
aggregation is defined by a specified function.
Combines two source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from either of the ObservableSources, where this
aggregation is defined by a specified function.
Combines three source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines four source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines an array of source ObservableSources by emitting an item that aggregates the latest values of each of
the ObservableSources each time an item is received from any of the returned ObservableSources, where this
aggregation is defined by a specified function.
Combines an array of source ObservableSources by emitting an item that aggregates the latest values of each of
the ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
Combines an array of ObservableSources by emitting an item that aggregates the latest values of each of
the ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
Combines an array of ObservableSources by emitting an item that aggregates the latest values of each of
the ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
Combines an Iterable of ObservableSources by emitting an item that aggregates the latest values of each of
the ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
Combines an Iterable of ObservableSources by emitting an item that aggregates the latest values of each of
the ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
A functional interface that has a subscribe() method that receives
a CompletableEmitter instance that allows pushing
an event in a cancellation-safe manner.
Returns a Flowable that emits the items emitted by each of the Publishers emitted by the source
Publisher, one after the other, without interleaving them.
Returns a Flowable that emits the items emitted by each of the Publishers emitted by the source
Publisher, one after the other, without interleaving them.
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the
ObservableSource, one after the other, without interleaving them.
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the outer
ObservableSource, one after the other, without interleaving them.
Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by
a Publisher sequence and prefetched by the specified amount.
Concatenates the Iterable sequence of Publishers 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 Publishers terminate.
Concatenates the Publisher sequence of Publishers 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 Publishers terminate.
Concatenates the Publisher sequence of Publishers 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 Publishers terminate.
Concatenates the Iterable sequence of MaybeSources 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 MaybeSources terminate
as a Flowable sequence.
Concatenates the Publisher sequence of MaybeSources 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.
Concatenates the Publisher sequence of MaybeSources 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.
Concatenates the Iterable sequence of ObservableSources 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 ObservableSources terminate.
Concatenates the ObservableSource sequence of ObservableSources 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 ObservableSources terminate.
Concatenates the ObservableSource sequence of ObservableSources 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 ObservableSources terminate.
Concatenates the Iterable sequence of SingleSources 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 SingleSources terminate
as a Flowable sequence.
Concatenates the Publisher sequence of SingleSources 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.
Concatenates the Publisher sequence of SingleSources 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.
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values
and runs a limited number of inner sequences at once.
Concatenates a Publisher sequence of SingleSources eagerly into a single stream of values and
runs a limited number of those inner SingleSources at once.
Concatenates a sequence of Publishers 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.
Concatenates a Publisher sequence of Publishers eagerly into a single stream of values,
delaying errors until all the inner and the outer sequences terminate.
Concatenates a Publisher sequence of Publishers 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.
Concatenates a sequence of MaybeSources eagerly into a Flowable sequence,
delaying errors until all inner MaybeSources terminate and
runs a limited number of inner MaybeSources at once.
Concatenates a Publisher sequence of MaybeSources eagerly into a Flowable sequence,
delaying errors until all the inner and the outer sequence terminate.
Concatenates a Publisher sequence of MaybeSources eagerly into a Flowable sequence,
delaying errors until all the inner and the outer sequence terminate and
runs a limited number of the inner MaybeSources at once.
Concatenates a sequence of ObservableSources 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.
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values,
delaying errors until all the inner and the outer sequence terminate.
Concatenates an ObservableSource sequence of ObservableSources 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.
Concatenates a Publisher sequence of SingleSources eagerly into a single stream of values,
delaying errors until all the inner and the outer sequence terminate.
Concatenates a Publisher sequence of SingleSources eagerly into a single stream of values,
running at most the specified number of those inner SingleSources at once and
delaying errors until all the inner and the outer sequence terminate.
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 Publishers.
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 Publishers.
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 Publishers.
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 ObservableSources.
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 ObservableSources.
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 ObservableSources.
Generates and concatenates Publishers on each 'rail', signalling errors immediately
and using the given prefetch amount for generating Publishers upfront.
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.
Maps each element of the current Observable into CompletableSources, subscribes to them one at a time in
order and waits until the upstream and all CompletableSources complete.
Maps each element of the current Observable into CompletableSources, subscribes to them one at a time in
order and waits until the upstream and all CompletableSources complete.
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.
Maps the upstream items into CompletableSources and subscribes to them one after the
other terminates, delaying all errors till both this Flowable and all
inner CompletableSources terminate.
Maps the upstream items into CompletableSources and subscribes to them one after the
other terminates, optionally delaying all errors till both this Flowable and all
inner CompletableSources terminate.
Maps the upstream items into CompletableSources and subscribes to them one after the
other terminates, optionally delaying all errors till both this Flowable and all
inner CompletableSources terminate.
Maps the upstream items into CompletableSources and subscribes to them one after the
other terminates, delaying all errors till both the current Observable and all
inner CompletableSources terminate.
Maps the upstream items into CompletableSources and subscribes to them one after the
other terminates, optionally delaying all errors till both the current Observable and all
inner CompletableSources terminate.
Maps the upstream items into CompletableSources and subscribes to them one after the
other terminates, optionally delaying all errors till both the current Observable and all
inner CompletableSources terminate.
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 Publishers
till all of them terminate.
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 Publishers
till all of them terminate.
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 Publishers till all of them terminate.
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 ObservableSources
till all of them terminate.
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 ObservableSources
till all of them terminate.
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 ObservableSources
till all of them terminate.
Generates and concatenates Publishers on each 'rail', optionally delaying errors
and using the given prefetch amount for generating Publishers upfront.
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.
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.
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.
Maps the upstream items into MaybeSources 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.
Maps the upstream items into MaybeSources 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.
Maps the upstream items into MaybeSources 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.
Maps the upstream items into MaybeSources 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.
Maps the upstream items into MaybeSources 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 MaybeSources terminate.
Maps the upstream items into MaybeSources 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 MaybeSources terminate.
Maps the upstream items into MaybeSources 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 MaybeSources terminate.
Maps the upstream items into MaybeSources 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 MaybeSources terminate.
Maps the upstream items into MaybeSources 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 MaybeSources terminate.
Maps the upstream items into MaybeSources 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 MaybeSources terminate.
Maps the upstream items into SingleSources 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.
Maps the upstream items into SingleSources 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.
Maps the upstream items into SingleSources 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.
Maps the upstream items into SingleSources 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.
Maps the upstream items into SingleSources 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 SingleSources terminate.
Maps the upstream items into SingleSources 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 SingleSources terminate.
Maps the upstream items into SingleSources 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 SingleSources terminate.
Maps the upstream items into SingleSources 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 SingleSources terminate.
Maps the upstream items into SingleSources 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 SingleSources terminate.
Maps the upstream items into SingleSources 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 SingleSources terminate.
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.
Returns an Observable that first emits the items emitted from the current Observable, then items
from the otherObservableSource without interleaving them.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
Returns an Observable that delays the subscription to and emissions from the current Observable via
ObservableSources for the subscription itself and on a per-item basis.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
Returns an Observable that forwards the items and terminal events of the current
Observable to its Observers and to the given shared Observer instance.
Returns a Completable which calls the given onEventConsumer with the Throwable for an onError
or null for an onComplete signal from this Completable before delivering the signal to the downstream.
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.
Call the specified consumer with the current element passing through any 'rail' and
handles errors based on the given ParallelFailureHandling enumeration value.
Call the specified consumer with the current element passing through any 'rail' and
handles errors based on the returned value by the handler function.
Returns a Completable instance that calls the given onSubscribe callback with the disposable
that the downstream CompletableObservers receive upon subscription.
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.
Returns a Maybe that emits the single item at a specified index in a sequence of emissions from
this Flowable or completes if this Flowable sequence has fewer elements than index.
Returns a Single that emits the item found at a specified index in a sequence of emissions from
this Flowable, or a default item if that index is out of range.
Returns a Maybe that emits the single item at a specified index in a sequence of emissions from
the current Observable or completes if the current Observable signals fewer elements than index.
Returns a Single that emits the item found at a specified index in a sequence of emissions from
the current Observable, or a default item if that index is out of range.
Returns a Single that emits the item found at a specified index in a sequence of emissions from
this Flowable or signals a NoSuchElementException if this Flowable has fewer elements than index.
Returns a Single that emits the item found at a specified index in a sequence of emissions from the current Observable
or signals a NoSuchElementException if the current Observable signals fewer elements than index.
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.
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.
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
Publishers and emitting the results of this merger.
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
Publishers and emitting the results of this merger.
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
Publishers and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publishers.
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
Publishers and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publishers.
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
Publishers and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publishers.
Returns a Flowable that applies a function to each item emitted or notification raised by the current
Flowable and then flattens the Publishers returned from these functions and emits the resulting items.
Returns a Flowable that applies a function to each item emitted or notification raised by the current
Flowable and then flattens the Publishers returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Publishers.
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.
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.
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 Publishers.
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 Publishers.
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 Publishers.
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
ObservableSources and emitting the results of this merger.
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
ObservableSources and emitting the results of this merger.
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
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
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
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
Returns an Observable that applies a function to each item emitted or notification raised by the current
Observable and then flattens the ObservableSources returned from these functions and emits the resulting items.
Returns an Observable that applies a function to each item emitted or notification raised by the current
Observable and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
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
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
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.
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.
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 ObservableSources.
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 ObservableSources.
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 ObservableSources.
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.
Generates and flattens Publishers on each 'rail', optionally delaying errors
and having a total number of simultaneous subscriptions to the inner Publishers.
Generates and flattens Publishers on each 'rail', optionally delaying errors,
having a total number of simultaneous subscriptions to the inner Publishers
and using the given prefetch amount for the inner Publishers.
Maps each element of the upstream Flowable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete.
Maps each element of the upstream Flowable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete, optionally delaying all errors.
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.
Maps each element of the current Observable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete.
Maps each element of the current Observable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete, optionally delaying all errors.
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.
Merges Iterables 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 resultSelectorBiFunction.
Merges Iterables 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 resultSelectorBiFunction.
Merges Iterables 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 resultSelectorBiFunction.
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.
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.
Maps each element of the upstream Flowable into MaybeSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Flowable sequence.
Maps each element of the upstream Flowable into MaybeSources, subscribes to at most
maxConcurrencyMaybeSources at a time and merges their onSuccess values,
in no particular order, into a single Flowable sequence, optionally delaying all errors.
Maps each element of the current Observable into MaybeSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Observable sequence.
Maps each element of the current Observable into MaybeSources, subscribes to them
and merges their onSuccess values, in no particular order, into a single Observable sequence,
optionally delaying all errors.
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.
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.
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.
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.
Maps each element of the upstream Flowable into SingleSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Flowable sequence.
Maps each element of the upstream Flowable into SingleSources, subscribes to at most
maxConcurrencySingleSources at a time and merges their onSuccess values,
in no particular order, into a single Flowable sequence, optionally delaying all errors.
Maps each element of the current Observable into SingleSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Observable sequence.
Maps each element of the current Observable into SingleSources, subscribes to them
and merges their onSuccess values, in no particular order, into a single Observable sequence,
optionally delaying all errors.
The Flowable class that implements the Reactive StreamsPublisher
Pattern and offers factory methods, intermediate operators and the ability to consume reactive dataflows.
Abstraction over a Reactive Streams Subscriber that allows associating
a resource with it and exposes the current number of downstream
requested amount.
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.
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.
Subscribes to the ObservableSource and calls a Predicate for each item of the current Observable,
on its emission thread, until the predicate returns false.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
Returns an Observable that emits a 0L after the initialDelay and ever increasing numbers
after each period of time thereafter, on a specified Scheduler.
Default implementations for Disposable-based resource management
(Disposable container types) and utility classes to construct
Disposables from callbacks and other types.
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.
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.
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.
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.
Returns a Single that emits only the last item emitted by the current Observable, or a default item
if the current Observable completes without emitting any items.
Returns a Single that emits only the last item emitted by the current Observable or
signals a NoSuchElementException if the current Observable is empty.
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns a Completable which, when subscribed to, invokes the apply(CompletableObserver) method
of the provided CompletableOperator for each individual downstream Completable and allows the
insertion of a custom operator by accessing the downstream's CompletableObserver during this subscription phase
and providing a new CompletableObserver, containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream.
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns a Flowable which, when subscribed to, invokes the apply(Subscriber) method
of the provided FlowableOperator for each individual downstream Subscriber and allows the
insertion of a custom operator by accessing the downstream's Subscriber during this subscription phase
and providing a new Subscriber, containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream.
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns a Maybe which, when subscribed to, invokes the apply(MaybeObserver) method
of the provided MaybeOperator for each individual downstream Maybe and allows the
insertion of a custom operator by accessing the downstream's MaybeObserver during this subscription phase
and providing a new MaybeObserver, containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream.
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns an Observable which, when subscribed to, invokes the apply(Observer) method
of the provided ObservableOperator for each individual downstream Observer and allows the
insertion of a custom operator by accessing the downstream's Observer during this subscription phase
and providing a new Observer, containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream.
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns a Single which, when subscribed to, invokes the apply(SingleObserver) method
of the provided SingleOperator for each individual downstream Single and allows the
insertion of a custom operator by accessing the downstream's SingleObserver during this subscription phase
and providing a new SingleObserver, containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream.
Returns a Flowable that applies a specified function to each item emitted by the current Flowable and
emits the results of these function applications.
Returns an Observable that applies a specified function to each item emitted by the current Observable and
emits the results of these function applications.
Maps the source values on each 'rail' to an optional and emits its value if any and
handles errors based on the given ParallelFailureHandling enumeration value.
Maps the source values on each 'rail' to an optional and emits its value if any and
handles errors based on the returned value by the handler function.
Returns a Flowable that represents all of the emissions and notifications from the current
Flowable into emissions marked with their original types within Notification objects.
Returns an Observable that represents all of the emissions and notifications from the current
Observable into emissions marked with their original types within Notification objects.
Returns a Completable instance that subscribes to all sources at once and
completes only when all source CompletableSources complete or one of them emits an error.
Returns a Completable instance that subscribes to all sources at once and
completes only when all source CompletableSources complete or one of them emits an error.
Returns a Completable instance that keeps subscriptions to a limited number of sources at once and
completes only when all source CompletableSources complete or one of them emits an error.
Flattens an Iterable of Publishers into one Publisher, without any transformation, while limiting the
number of concurrent subscriptions to these Publishers.
Flattens an Iterable of Publishers into one Publisher, without any transformation, while limiting the
number of concurrent subscriptions to these Publishers.
Flattens a Publisher that emits Publishers into a single Publisher that emits the items emitted by
those Publishers, without any transformation, while limiting the maximum number of concurrent
subscriptions to these Publishers.
Flattens a MaybeSource that emits a MaybeSource into a single MaybeSource that emits the item
emitted by the nested MaybeSource, without any transformation.
Flattens an Iterable of ObservableSources into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
Flattens an Iterable of ObservableSources into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
Flattens an ObservableSource that emits ObservableSources into a single Observable that emits the items emitted by
those ObservableSources, without any transformation.
Flattens an ObservableSource that emits ObservableSources into a single Observable that emits the items emitted by
those ObservableSources, without any transformation, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
Flattens a SingleSource that emits a SingleSingle into a single Single that emits the item
emitted by the nested SingleSource, without any transformation.
Returns a Completable instance that subscribes to all sources at once and
completes only when all source CompletableSources complete or one of them emits an error.
Flattens an array of Publishers into one Publisher, without any transformation, while limiting the
number of concurrent subscriptions to these Publishers.
Flattens an array of ObservableSources into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
Returns a Completable that subscribes to all CompletableSources in the source array and delays
any error emitted by any of the inner CompletableSources until all of
them terminate in a way or another.
Flattens an array of Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publishers without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these Publishers.
Flattens an array of Publishers into one Flowable, in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publishers without being interrupted by an error
notification from one of them.
Flattens an array of MaybeSources into one Flowable, in a way that allows a subscriber to receive all
successfully emitted items from each of the source MaybeSources without being interrupted by an error
notification from one of them.
Flattens an array of ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
Flattens an array of ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the ObservableSources without being interrupted by an error
notification from one of them.
Flattens an array of SingleSources into one Flowable, in a way that allows a subscriber to receive all
successfully emitted items from each of the source SingleSources without being interrupted by an error
notification from one of them.
Returns a Completable that subscribes to all CompletableSources in the source sequence and delays
any error emitted by any of the inner CompletableSources until all of
them terminate in a way or another.
Returns a Completable that subscribes to all CompletableSources in the source sequence and delays
any error emitted by either the sources Publisher or any of the inner CompletableSources until all of
them terminate in a way or another.
Returns a Completable that subscribes to a limited number of inner CompletableSources at once in
the source sequence and delays any error emitted by either the sources
Publisher or any of the inner CompletableSources until all of
them terminate in a way or another.
Flattens an Iterable of Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publishers without being interrupted by an error
notification from one of them.
Flattens an Iterable of Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publishers without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these Publishers.
Flattens an Iterable of Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publishers without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these Publishers.
Flattens a Publisher that emits Publishers into one Publisher, in a way that allows a Subscriber to
receive all successfully emitted items from all of the source Publishers without being interrupted by
an error notification from one of them.
Flattens a Publisher that emits Publishers into one Publisher, in a way that allows a Subscriber to
receive all successfully emitted items from all of the source Publishers without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these Publishers.
Flattens two Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publishers without being interrupted by an error
notification from one of them.
Flattens three Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from all of the source Publishers without being interrupted by an error
notification from one of them.
Flattens four Publishers into one Publisher, in a way that allows a Subscriber to receive all
successfully emitted items from all of the source Publishers without being interrupted by an error
notification from one of them.
Flattens an Iterable sequence of MaybeSources into one Flowable, in a way that allows a subscriber to receive all
successfully emitted items from each of the source MaybeSources without being interrupted by an error
notification from one of them.
Flattens a Publisher that emits MaybeSources into one Flowable, in a way that allows a subscriber to
receive all successfully emitted items from all of the source MaybeSources without being interrupted by
an error notification from one of them or even the main Publisher.
Flattens a Publisher that emits MaybeSources into one Flowable, in a way that allows a subscriber to
receive all successfully emitted items from all of the source MaybeSources without being interrupted by
an error notification from one of them or even the main Publisher as well as limiting the total number of active MaybeSources.
Flattens two MaybeSources into one Flowable, in a way that allows a subscriber to receive all
successfully emitted items from each of the source MaybeSources without being interrupted by an error
notification from one of them.
Flattens three MaybeSource into one Flowable, in a way that allows a subscriber to receive all
successfully emitted items from all of the source MaybeSources without being interrupted by an error
notification from one of them.
Flattens four MaybeSources into one Flowable, in a way that allows a subscriber to receive all
successfully emitted items from all of the source MaybeSources without being interrupted by an error
notification from one of them.
Flattens an Iterable of ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the returned ObservableSources without being interrupted by an error
notification from one of them.
Flattens an Iterable of ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the returned ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
Flattens an Iterable of ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the returned ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
Flattens an ObservableSource that emits ObservableSources into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the emitted ObservableSources without being interrupted by
an error notification from one of them.
Flattens an ObservableSource that emits ObservableSources into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the emitted ObservableSources without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these ObservableSources.
Flattens two ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the ObservableSources without being interrupted by an error
notification from one of them.
Flattens three ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the ObservableSources without being interrupted by an error
notification from one of them.
Flattens four ObservableSources into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the ObservableSources without being interrupted by an error
notification from one of them.
Merges an Iterable sequence of SingleSource instances into one Flowable sequence,
running all SingleSources at once and delaying any error(s) until all sources succeed or fail.
Merges a sequence of SingleSource instances emitted by a Publisher into a Flowable sequence,
running all SingleSources at once and delaying any error(s) until all sources succeed or fail.
Merges the sequence of items of this Flowable with the success value of the other MaybeSource
or waits for both to complete normally if the MaybeSource is empty.
Merges the sequence of items of the current Observable with the success value of the other MaybeSource
or waits both to complete normally if the MaybeSource is empty.
A FlowableProcessor implementation that coordinates downstream requests through
a front-buffer and stable-prefetching, optionally canceling the upstream if all
subscribers have cancelled.
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.
A functional interface that has a subscribe() method that receives
an ObservableEmitter instance that allows pushing
events in a cancellation-safe manner.
Signals the items and terminal signals of the current Flowable on the specified Scheduler,
asynchronously with a bounded buffer of Flowable.bufferSize() slots.
Signals the items and terminal signals of the current Flowable on the specified Scheduler,
asynchronously with a bounded buffer and optionally delays onError notifications.
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.
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".
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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).
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
Customizes the Throwable with a custom message and wraps it before it
is signalled to the RxJavaPlugins.onError() handler as OnErrorNotImplementedException.
Returns a Completable instance that when encounters an error from this Completable, calls the
specified mapperFunction that returns a CompletableSource instance for it and resumes the
execution with it.
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.
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.
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.
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.
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.
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.
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.
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.
Provides the Observer with the means of cancelling (disposing) the
connection (channel) with the Observable in both
synchronous (from within Observer.onNext(Object)) and asynchronous manner.
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.
Parallelizes the flow by creating the specified number of 'rails'
and dispatches the upstream items to them in a round-robin fashion and
uses the defined per-'rail' prefetch amount.
Returns a ConnectableFlowable, which is a variety of Publisher that waits until its
connect method is called before it begins emitting items to those
Subscribers that have subscribed to it.
Returns a Flowable that emits the results of invoking a specified selector on items emitted by a
ConnectableFlowable that shares a single subscription to the underlying sequence.
Returns a Flowable that emits the results of invoking a specified selector on items emitted by a
ConnectableFlowable that shares a single subscription to the underlying sequence.
Returns a ConnectableFlowable, which is a variety of Publisher that waits until its
connect method is called before it begins emitting items to those
Subscribers that have subscribed to it.
Returns an Observable that emits the results of invoking a specified selector on items emitted by a
ConnectableObservable that shares a single subscription to the current Observable sequence.
An interface extending SimpleQueue and Disposable and allows negotiating
the fusion mode between subsequent operators of the Observable base reactive type.
Indicates an overflow happened because the upstream disregarded backpressure completely or
Subscriber.onNext(Object) was called concurrently from multiple threads
without synchronization.
An interface extending SimpleQueue and Subscription and allows negotiating
the fusion mode between subsequent operators of the Flowable base reactive type.
Returns a Maybe that applies a specified accumulator function to the first item emitted by the current
Flowable, then feeds the result of that function along with the second item emitted by the current
Flowable into the same function, and so on until all items have been emitted by the current and finite Flowable,
and emits the final result from the final call to your function as its sole item.
Returns a Single that applies a specified accumulator function to the first item emitted by the current
Flowable and a specified seed value, then feeds the result of that function along with the second item
emitted by the current Flowable into the same function, and so on until all items have been emitted by the
current and finite Flowable, emitting the final result from the final call to your function as its sole item.
Returns a Maybe that applies a specified accumulator function to the first item emitted by the current
Observable, then feeds the result of that function along with the second item emitted by the current
Observable into the same function, and so on until all items have been emitted by the current and finite Observable,
and emits the final result from the final call to your function as its sole item.
Returns a Single that applies a specified accumulator function to the first item emitted by the current
Observable and a specified seed value, then feeds the result of that function along with the second item
emitted by the current Observable into the same function, and so on until all items have been emitted by the
current and finite Observable, emitting the final result from the final call to your function as its sole item.
Reduces all values within a 'rail' to a single value (with a possibly different type) via
a reducer function that is initialized on each rail from an initialSupplier value.
Returns a Single that applies a specified accumulator function to the first item emitted by the current
Flowable and a seed value derived from calling a specified seedSupplier, then feeds the result
of that function along with the second item emitted by the current Flowable into the same function, and so on until
all items have been emitted by the current and finite Flowable, emitting the final result from the final call to your
function as its sole item.
Returns a Single that applies a specified accumulator function to the first item emitted by the current
Observable and a seed value derived from calling a specified seedSupplier, then feeds the result
of that function along with the second item emitted by the current Observable into the same function,
and so on until all items have been emitted by the current and finite Observable, emitting the final result
from the final call to your function as its sole item.
Connects to the upstream ConnectableFlowable if the number of subscribed
subscriber reaches the specified count and disconnect if all subscribers have unsubscribed.
Connects to the upstream ConnectableFlowable if the number of subscribed
subscriber reaches 1 and disconnect after the specified
timeout if all subscribers have unsubscribed.
Connects to the upstream ConnectableFlowable if the number of subscribed
subscriber reaches 1 and disconnect after the specified
timeout if all subscribers have unsubscribed.
Connects to the upstream ConnectableFlowable if the number of subscribed
subscriber reaches the specified count and disconnect after the specified
timeout if all subscribers have unsubscribed.
Connects to the upstream ConnectableFlowable if the number of subscribed
subscriber reaches the specified count and disconnect after the specified
timeout if all subscribers have unsubscribed.
Connects to the upstream ConnectableObservable if the number of subscribed
observers reaches the specified count and disconnect if all Observers have unsubscribed.
Connects to the upstream ConnectableObservable if the number of subscribed
observers reaches 1 and disconnect after the specified
timeout if all Observers have unsubscribed.
Connects to the upstream ConnectableObservable if the number of subscribed
observers reaches 1 and disconnect after the specified
timeout if all Observers have unsubscribed.
Connects to the upstream ConnectableObservable if the number of subscribed
observers reaches the specified count and disconnect after the specified
timeout if all Observers have unsubscribed.
Connects to the upstream ConnectableObservable if the number of subscribed
observers reaches the specified count and disconnect after the specified
timeout if all Observers have unsubscribed.
Returns a Completable instance that repeats when the Publisher returned by the handler Function
emits an item or completes when this Publisher emits an onComplete event.
Re-subscribes to the current Single if
the Publisher returned by the handler function signals a value in response to a
value signaled through the Flowable the handler receives.
Returns a ConnectableFlowable that shares a single subscription to the underlying Publisher
that will replay all of its items and notifications to any future Subscriber.
Returns a Flowable that emits items that are the results of invoking a specified selector on the items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying bufferSize notifications.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying bufferSize notifications.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying no more than bufferSize items that were emitted within a specified time window.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying no more than bufferSize items that were emitted within a specified time window.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying no more than bufferSize items that were emitted within a specified time window.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying all items that were emitted within a specified time window.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying all items that were emitted within a specified time window.
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableFlowable that shares a single subscription to the current Flowable,
replaying all items that were emitted within a specified time window.
Returns a ConnectableFlowable that shares a single subscription to the current Flowable and
replays at most bufferSize items that were emitted during a specified time window.
Returns a ConnectableFlowable that shares a single subscription to the current Flowable and
replays a maximum of bufferSize items that are emitted within a specified time window to late Subscribers.
Returns a ConnectableFlowable that shares a single subscription to the current Flowable and
replays a maximum of bufferSize items that are emitted within a specified time window to late Subscribers.
Returns a ConnectableFlowable that shares a single subscription to the current Flowable and
replays all items emitted by it within a specified time window to late Subscribers.
Returns a ConnectableFlowable that shares a single subscription to the current Flowable and
replays all items emitted by it within a specified time window to late Subscribers.
Returns a ConnectableFlowable that shares a single subscription to the current Flowable and
replays all items emitted by it within a specified time window to late Subscribers.
Returns a ConnectableObservable that shares a single subscription to the current Observable
that will replay all of its items and notifications to any future Observer.
Returns an Observable that emits items that are the results of invoking a specified selector on the items
emitted by a ConnectableObservable that shares a single subscription to the current Observable.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying bufferSize notifications.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying bufferSize notifications.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying no more than bufferSize items that were emitted within a specified time window.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying no more than bufferSize items that were emitted within a specified time window.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying no more than bufferSize items that were emitted within a specified time window.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying all items that were emitted within a specified time window.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying all items that were emitted within a specified time window.
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a ConnectableObservable that shares a single subscription to the current Observable,
replaying all items that were emitted within a specified time window.
Returns a ConnectableObservable that shares a single subscription to the current Observable that
replays at most bufferSize items emitted by the current Observable.
Returns a ConnectableObservable that shares a single subscription to the current Observable that
replays at most bufferSize items emitted by the current Observable.
Returns a ConnectableObservable that shares a single subscription to the current Observable and
replays at most bufferSize items that were emitted during a specified time window.
Returns a ConnectableObservable that shares a single subscription to the current Observable and
that replays a maximum of bufferSize items that are emitted within a specified time window.
Returns a ConnectableObservable that shares a single subscription to the current Observable and
that replays a maximum of bufferSize items that are emitted within a specified time window.
Returns a ConnectableObservable that shares a single subscription to the current Observable and
replays all items emitted by the current Observable within a specified time window.
Returns a ConnectableObservable that shares a single subscription to the current Observable and
replays all items emitted by the current Observable within a specified time window.
Returns a ConnectableObservable that shares a single subscription to the current Observable and
replays all items emitted by the current Observable within a specified time window.
Returns a Completable that when this Completable emits an error, retries at most the given
number of times before giving up and emitting the last error.
Returns a Completable that when this Completable emits an error, retries at most times
or until the predicate returns false, whichever happens first and emitting the last error.
Returns a Completable that when this Completable emits an error, calls the given predicate with
the latest Throwable to decide whether to resubscribe to the upstream or not.
retry() - Method in class io.reactivex.rxjava3.core.Flowable
Returns a Flowable that mirrors the current Flowable, resubscribing to it if it calls onError
(infinite retry count).
Returns a Flowable that mirrors the current Flowable, resubscribing to it if it calls onError
and the predicate returns true for that specific exception and retry count.
Returns a Maybe that mirrors the current Maybe, resubscribing to it if it calls onError
and the predicate returns true for that specific exception and retry count.
Returns an Observable that mirrors the current Observable, resubscribing to it if it calls onError
and the predicate returns true for that specific exception and retry count.
Returns a Completable which given a Publisher and when this Completable emits an error, delivers
that error through a Flowable and the Publisher should signal a value indicating a retry in response
or a terminal event indicating a termination.
Subscribes to the current Flowable and wraps the given Subscriber into a SafeSubscriber
(if not already a SafeSubscriber) that
deals with exceptions thrown by a misbehaving Subscriber (that doesn't follow the
Reactive Streams specification).
Subscribes to the current Observable and wraps the given Observer into a SafeObserver
(if not already a SafeObserver) that
deals with exceptions thrown by a misbehaving Observer (that doesn't follow the
Reactive Streams specification).
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals and optionally emit the very last upstream item when the upstream completes.
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals, where the intervals are defined on a particular Scheduler.
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals, where the intervals are defined on a particular Scheduler
and optionally emit the very last upstream item when the upstream completes.
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals, where the intervals are defined on a particular Scheduler
and optionally emit the very last upstream item when the upstream completes.
Returns a Flowable that, when the specified samplerPublisher emits an item or completes,
emits the most recently emitted item (if any) emitted by the current Flowable since the previous
emission from the samplerPublisher.
Returns a Flowable that, when the specified samplerPublisher emits an item or completes,
emits the most recently emitted item (if any) emitted by the current Flowable since the previous
emission from the samplerPublisher
and optionally emit the very last upstream item when the upstream or other Publisher complete.
Returns an Observable that emits the most recently emitted item (if any) emitted by the current Observable
within periodic time intervals and optionally emit the very last upstream item when the upstream completes.
Returns an Observable that emits the most recently emitted item (if any) emitted by the current Observable
within periodic time intervals, where the intervals are defined on a particular Scheduler.
Returns an Observable that emits the most recently emitted item (if any) emitted by the current Observable
within periodic time intervals, where the intervals are defined on a particular Scheduler
and optionally emit the very last upstream item when the upstream completes.
Returns an Observable that emits the most recently emitted item (if any) emitted by the current Observable
within periodic time intervals, where the intervals are defined on a particular Scheduler.
Returns an Observable that, when the specified samplerObservableSource emits an item or completes,
emits the most recently emitted item (if any) emitted by the current Observable since the previous
emission from the samplerObservableSource.
Returns an Observable that, when the specified samplerObservableSource emits an item or completes,
emits the most recently emitted item (if any) emitted by the current Observable since the previous
emission from the samplerObservableSource
and optionally emit the very last upstream item when the upstream or other ObservableSource complete.
A marker interface indicating that a scalar, constant value
is held by the implementing reactive type which can be
safely extracted during assembly time can be used for
optimization.
Returns a Flowable that emits the first value emitted by the current Flowable, then emits one value
for each subsequent value emitted by the current Flowable.
Returns an Observable that emits the first value emitted by the current Observable, then emits one value
for each subsequent value emitted by the current Observable.
A Scheduler is an object that specifies an API for scheduling
units of work provided in the form of Runnables to be
executed without delay (effectively as soon as possible), after a specified time delay or periodically
and represents an abstraction over an asynchronous boundary that ensures
these units of work get executed by some underlying task-execution scheme
(such as custom Threads, event loop, Executor or Actor system)
with some uniform properties and guarantees regardless of the particular underlying
scheme.
Represents an isolated, sequential worker of a parent Scheduler for executing Runnable tasks on
an underlying task-execution scheme (such as custom Threads, event loop, Executor or Actor system).
Returns a Single that emits a Boolean value that indicates whether two Publisher sequences are the
same by comparing the items emitted by each Publisher pairwise.
Returns a Single that emits a Boolean value that indicates whether two Publisher sequences are the
same by comparing the items emitted by each Publisher pairwise based on the results of a specified
equality function.
Returns a Single that emits a Boolean value that indicates whether two Publisher sequences are the
same by comparing the items emitted by each Publisher pairwise based on the results of a specified
equality function.
Returns a Single that emits a Boolean value that indicates whether two Publisher sequences are the
same by comparing the items emitted by each Publisher pairwise.
Returns a Single that emits a Boolean value that indicates whether two MaybeSource sequences are the
same by comparing the items emitted by each MaybeSource pairwise.
Returns a Single that emits a Boolean value that indicates whether two MaybeSources are the
same by comparing the items emitted by each MaybeSource pairwise based on the results of a specified
equality function.
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
Merges the values from each 'rail' in a round-robin or same-order fashion and
exposes it as a regular Flowable sequence, running with a default prefetch value
for the rails.
Merges the values from each 'rail' in a round-robin or same-order fashion and
exposes it as a regular Flowable sequence, running with a give prefetch value
for the rails.
Merges the values from each 'rail' in a round-robin or same-order fashion and
exposes it as a regular Flowable sequence, running with a default prefetch value
for the rails and delaying errors from all rails till all terminate.
Merges the values from each 'rail' in a round-robin or same-order fashion and
exposes it as a regular Flowable sequence, running with a give prefetch value
for the rails and delaying errors from all rails till all terminate.
A Disposable container that allows atomically updating/replacing the contained
Disposable with another Disposable, disposing the old one when updating plus
handling the disposition when the container itself is disposed.
Construct a SerializedObserver by wrapping the given actual Observer and
optionally delaying the errors till all regular values have been emitted
from the internal buffer.
Construct a SerializedSubscriber by wrapping the given actual Subscriber and
optionally delaying the errors till all regular values have been emitted
from the internal buffer.
Set the handler that is called when an operator attempts a blocking
await; the handler should return true to prevent the blocking
and to signal an IllegalStateException instead.
Instructs the Scheduler instance to stop threads,
stop accepting tasks on any outstanding Scheduler.Worker instances
and clean up any associated resources with this Scheduler.
Returns a Single that emits the single item emitted by the current Flowable if it
emits only a single item, or a default item if the current Flowable emits no items.
Returns a Single that emits the single item emitted by the current Observable, if the current Observable
emits only a single item, or a default item if the current Observable emits no items.
Returns a Maybe that completes if this Flowable is empty, signals one item if this Flowable
signals exactly one item or signals an IllegalArgumentException if this Flowable signals
more than one item.
Returns a Maybe that completes if the current Observable is empty or emits the single item
emitted by the current Observable, or signals an IllegalArgumentException if the current
Observable emits more than one item.
A functional interface that has a subscribe() method that receives
a SingleEmitter instance that allows pushing
an event in a cancellation-safe manner.
Returns a Single that emits the single item emitted by this Flowable, if this Flowable
emits only a single item, otherwise
if this Flowable completes without emitting any items a NoSuchElementException will be signaled and
if this Flowable emits more than one item, an IllegalArgumentException will be signaled.
Returns a Single that emits the single item emitted by the current Observable if it
emits only a single item, otherwise
if the current Observable completes without emitting any items or emits more than one item a
NoSuchElementException or IllegalArgumentException will be signaled respectively.
Signals the only expected upstream item (or the default item if the upstream is empty)
or signals IllegalArgumentException if the upstream has more than one item
via a CompletionStage.
Signals the only expected upstream item (or the default item if the upstream is empty)
or signals IllegalArgumentException if the upstream has more than one item
via a CompletionStage.
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
(defined on a specified scheduler) before the source completes.
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
(defined on a specified scheduler) before the source completes.
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
(defined on a specified scheduler) before the source completes.
Returns an Observable that drops items emitted by the current Observable during a specified time window
(defined on a specified scheduler) before the source completes.
Returns an Observable that drops items emitted by the current Observable during a specified time window
(defined on a specified scheduler) before the source completes.
Returns an Observable that drops items emitted by the current Observable during a specified time window
(defined on a specified scheduler) before the source completes.
Returns a Flowable that skips all items emitted by the current Flowable as long as a specified
condition holds true, but emits all further source items as soon as the condition becomes false.
Returns an Observable that skips all items emitted by the current Observable as long as a specified
condition holds true, but emits all further source items as soon as the condition becomes false.
Initializes this Processor by setting an upstream Subscription that
ignores request amounts, uses a fixed buffer
and allows using the onXXX and offer methods
afterwards.
start() - Static method in class io.reactivex.rxjava3.schedulers.Schedulers
Initializes this Processor by setting an upstream Subscription that
ignores request amounts, uses an unbounded buffer
and allows using the onXXX and offer methods
afterwards.
Wraps the given onXXX callbacks into a DisposableCompletableObserver,
adds it to the given DisposableContainer and ensures, that if the upstream
terminates or this particular Disposable is disposed, the CompletableObserver is removed
from the given composite.
Wraps the given onXXX callbacks into a DisposableSubscriber,
adds it to the given DisposableContainer and ensures, that if the upstream
terminates or this particular Disposable is disposed, the Subscriber is removed
from the given container.
Establish a connection between this Flowable and the given FlowableSubscriber and
start streaming events based on the demand of the FlowableSubscriber.
Wraps the given onXXX callbacks into a DisposableMaybeObserver,
adds it to the given DisposableContainer and ensures, that if the upstream
terminates or this particular Disposable is disposed, the MaybeObserver is removed
from the given composite.
Wraps the given onXXX callbacks into a DisposableObserver,
adds it to the given DisposableContainer and ensures, that if the upstream
terminates or this particular Disposable is disposed, the Observer is removed
from the given container.
Wraps the given onXXX callbacks into a DisposableSingleObserver,
adds it to the given DisposableContainer and ensures, that if the upstream
terminates or this particular Disposable is disposed, the SingleObserver is removed
from the given container.
Operator implementations (both source and intermediate) should implement this method that
performs the necessary business logic and handles the incoming Subscribers.
Operator implementations (both source and intermediate) should implement this method that
performs the necessary business logic and handles the incoming Observers.
Returns a Completable which subscribes the downstream subscriber on the specified scheduler, making
sure the subscription side-effects happen on that specific thread of the Scheduler.
Asynchronously subscribes Subscribers to the current Flowable on the specified Scheduler
optionally reroutes requests from other threads to the same Scheduler thread.
Returns an Observable that emits the items emitted by the current Observable or the items of an alternate
ObservableSource if the current Observable is empty.
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers.
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers.
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
Maps the upstream values into CompletableSources, subscribes to the newer one while
disposing the subscription to the previous CompletableSource, thus keeping at most one
active CompletableSource running.
Maps the items of the current Observable into CompletableSources, subscribes to the newer one while
disposing the subscription to the previous CompletableSource, thus keeping at most one
active CompletableSource running.
Maps the upstream values into CompletableSources, subscribes to the newer one while
disposing the subscription to the previous CompletableSource, thus keeping at most one
active CompletableSource running and delaying any main or inner errors until all
of them terminate.
Maps the upstream values into CompletableSources, subscribes to the newer one while
disposing the subscription to the previous CompletableSource, thus keeping at most one
active CompletableSource running and delaying any main or inner errors until all
of them terminate.
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers and delays any error until all Publishers terminate.
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers and delays any error until all Publishers terminate.
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
Maps the upstream items into MaybeSources and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available while failing immediately if this Flowable or any of the
active inner MaybeSources fail.
Maps the items of the current Observable into MaybeSources and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available while failing immediately if the current Observable or any of the
active inner MaybeSources fail.
Maps the upstream items into MaybeSources and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available, delaying errors from this Flowable or the inner MaybeSources until all terminate.
Maps the upstream items into MaybeSources and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available, delaying errors from the current Observable or the inner MaybeSources until all terminate.
Maps the upstream items into SingleSources and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one
while failing immediately if this Flowable or any of the
active inner SingleSources fail.
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns a SingleSource, and then emitting the item emitted by the most recently emitted
of these SingleSources.
Maps the upstream items into SingleSources and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one,
delaying errors from this Flowable or the inner SingleSources until all terminate.
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns a SingleSource, and then emitting the item emitted by the most recently emitted
of these SingleSources and delays any error until all SingleSources terminate.
Switches between CompletableSources emitted by the source Publisher whenever
a new CompletableSource is emitted, disposing the previously running CompletableSource,
exposing the setup as a Completable sequence.
Switches between MaybeSources emitted by the source Publisher whenever
a new MaybeSource is emitted, disposing the previously running MaybeSource,
exposing the success items as a Flowable sequence.
Converts an ObservableSource that emits ObservableSources into an Observable that emits the items emitted by the
most recently emitted of those ObservableSources.
Converts an ObservableSource that emits ObservableSources into an Observable that emits the items emitted by the
most recently emitted of those ObservableSources.
Switches between SingleSources emitted by the source Publisher whenever
a new SingleSource is emitted, disposing the previously running SingleSource,
exposing the success items as a Flowable sequence.
Switches between CompletableSources emitted by the source Publisher whenever
a new CompletableSource is emitted, disposing the previously running CompletableSource,
exposing the setup as a Completable sequence and delaying all errors from
all of them until all terminate.
Converts a Publisher that emits Publishers into a Publisher that emits the items emitted by the
most recently emitted of those Publishers and delays any exception until all Publishers terminate.
Converts a Publisher that emits Publishers into a Publisher that emits the items emitted by the
most recently emitted of those Publishers and delays any exception until all Publishers terminate.
Switches between MaybeSources emitted by the source Publisher whenever
a new MaybeSource is emitted, disposing the previously running MaybeSource,
exposing the success items as a Flowable sequence and delaying all errors from
all of them until all terminate.
Converts an ObservableSource that emits ObservableSources into an Observable that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
Converts an ObservableSource that emits ObservableSources into an Observable that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
Switches between SingleSources emitted by the source Publisher whenever
a new SingleSource is emitted, disposing the previously running SingleSource,
exposing the success items as a Flowable sequence and delaying all errors from
all of them until all terminate.
SYNC - Static variable in interface io.reactivex.rxjava3.operators.QueueFuseable
Returns a Flowable that emits at most a specified number of items from the current Flowable that were
emitted in a specified window of time before the current Flowable completed.
Returns a Flowable that emits at most a specified number of items from the current Flowable that were
emitted in a specified window of time before the current Flowable completed, where the timing information is
provided by a given Scheduler.
Returns a Flowable that emits at most a specified number of items from the current Flowable that were
emitted in a specified window of time before the current Flowable completed, where the timing information is
provided by a given Scheduler.
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed.
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed.
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed, where the timing information is provided by a specified
Scheduler.
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed, where the timing information is provided by a specified
Scheduler.
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed, where the timing information is provided by a specified
Scheduler.
Returns an Observable that emits at most a specified number of items from the current Observable that were
emitted in a specified window of time before the current Observable completed.
Returns an Observable that emits at most a specified number of items from the current Observable that were
emitted in a specified window of time before the current Observable completed, where the timing information is
provided by a given Scheduler.
Returns an Observable that emits at most a specified number of items from the current Observable that were
emitted in a specified window of time before the current Observable completed, where the timing information is
provided by a given Scheduler.
Returns an Observable that emits the items from the current Observable that were emitted in a specified
window of time before the current Observable completed.
Returns an Observable that emits the items from the current Observable that were emitted in a specified
window of time before the current Observable completed.
Returns an Observable that emits the items from the current Observable that were emitted in a specified
window of time before the current Observable completed, where the timing information is provided by a specified
Scheduler.
Returns an Observable that emits the items from the current Observable that were emitted in a specified
window of time before the current Observable completed, where the timing information is provided by a specified
Scheduler.
Returns an Observable that emits the items from the current Observable that were emitted in a specified
window of time before the current Observable completed, where the timing information is provided by a specified
Scheduler.
Returns a Flowable that emits items emitted by the current Flowable, checks the specified predicate
for each item, and then completes when the condition is satisfied.
Returns an Observable that emits items emitted by the current Observable, checks the specified predicate
for each item, and then completes when the condition is satisfied.
Returns a Flowable that emits items emitted by the current Flowable so long as each item satisfied a
specified condition, and then completes as soon as this condition is not satisfied.
Returns an Observable that emits items emitted by the current Observable so long as each item satisfied a
specified condition, and then completes as soon as this condition is not satisfied.
A special, non thread-safe scheduler for testing operators that require
a scheduler without introducing real concurrency and allows manually advancing
a virtual time.
Creates a new TestScheduler with the specified initial virtual time
and with the option to use the
RxJavaPlugins.onSchedule(Runnable) hook when scheduling tasks.
Returns a Flowable that emits only the first item emitted by the current Flowable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler.
Returns a Flowable that emits only the first item emitted by the current Flowable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler.
Returns an Observable that emits only the first item emitted by the current Observable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler.
Returns an Observable that emits only the first item emitted by the current Observable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler.
Returns a Flowable that emits only the last item emitted by the current Flowable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler.
Returns a Flowable that emits only the last item emitted by the current Flowable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler.
Returns an Observable that emits only the last item emitted by the current Observable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler.
Returns an Observable that emits only the last item emitted by the current Observable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler.
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them, invoking the consumer for any dropped item.
Throttles items from the current Observable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the current Observable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the current Observable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the current Observable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
Throttles items from the current Observable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them, invoking the consumer for any dropped item.
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.
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.
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.
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.
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.
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.
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
current Flowable, where this interval is computed on a specified Scheduler.
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
current Flowable, where this interval is computed on a specified Scheduler.
Measures the time (in milliseconds) between the subscription and success item emission
of the current Maybe and signals it as a tuple (Timed)
success value.
Measures the time (in milliseconds) between the subscription and success item emission
of the current Maybe and signals it as a tuple (Timed)
success value.
Returns an Observable that emits records of the time interval between consecutive items emitted by the
current Observable, where this interval is computed on a specified Scheduler.
Returns an Observable that emits records of the time interval between consecutive items emitted by the
current Observable, where this interval is computed on a specified Scheduler.
Measures the time (in milliseconds) between the subscription and success item emission
of the current Single and signals it as a tuple (Timed)
success value.
Measures the time (in milliseconds) between the subscription and success item emission
of the current Single and signals it as a tuple (Timed)
success value.
Returns a Completable that runs this Completable and switches to the other CompletableSource
in case this Completable doesn't complete within the given time.
Returns a Completable that runs this Completable and emits a TimeoutException in case
this Completable doesn't complete within the given time while "waiting" on the specified
Scheduler.
Returns a Completable that runs this Completable and switches to the other CompletableSource
in case this Completable doesn't complete within the given time while "waiting" on
the specified Scheduler.
Returns a Flowable that mirrors the current Flowable, but notifies Subscribers of a
TimeoutException if an item emitted by the current Flowable doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by a Publisher that
is a function of the previous item.
Returns a Flowable that mirrors the current Flowable, but that switches to a fallback Publisher if
an item emitted by the current Flowable doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by a Publisher that is a function of the previous
item.
Returns a Flowable that mirrors the current Flowable but applies a timeout policy for each emitted
item, where this policy is governed by a specified Scheduler.
Returns a Flowable that mirrors the current Flowable, but notifies Subscribers of a
TimeoutException if either the first item emitted by the current Flowable or any subsequent item
doesn't arrive within time windows defined by other Publishers.
Returns a Flowable that mirrors the current Flowable, but switches to a fallback Publisher if either
the first item emitted by the current Flowable or any subsequent item doesn't arrive within time windows
defined by other Publishers.
Returns a Maybe that mirrors the current Maybe but applies a timeout policy for each emitted
item, where this policy is governed on a specified Scheduler.
If the current Maybe didn't signal an event before the timeoutIndicatorMaybeSource signals,
the current Maybe is disposed and the fallbackMaybeSource subscribed to
as a continuation.
If the current Maybe didn't signal an event before the timeoutIndicatorPublisher signals,
the current Maybe is disposed and the fallbackMaybeSource subscribed to
as a continuation.
Returns an Observable that mirrors the current Observable, but notifies observers of a
TimeoutException if an item emitted by the current Observable doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an ObservableSource that
is a function of the previous item.
Returns an Observable that mirrors the current Observable, but that switches to a fallback ObservableSource if
an item emitted by the current Observable doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an ObservableSource that is a function of the previous
item.
Returns an Observable that mirrors the current Observable but applies a timeout policy for each emitted
item, where this policy is governed on a specified Scheduler.
Returns an Observable that mirrors the current Observable, but notifies observers of a
TimeoutException if either the first item emitted by the current Observable or any subsequent item
doesn't arrive within time windows defined by indicator ObservableSources.
Returns an Observable that mirrors the current Observable, but switches to a fallback ObservableSource if either
the first item emitted by the current Observable or any subsequent item doesn't arrive within time windows
defined by indicator ObservableSources.
Returns a Flowable that emits each item emitted by the current Flowable, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler.
Returns a Flowable that emits each item emitted by the current Flowable, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler.
Combines the success value from the current Maybe with the current time (in milliseconds) of
its reception, using the computationScheduler as time source,
then signals them as a Timed instance.
Combines the success value from the current Maybe with the current time (in milliseconds) of
its reception, using the given Scheduler as time source,
then signals them as a Timed instance.
Combines the success value from the current Maybe with the current time of
its reception, using the computationScheduler as time source,
then signals it as a Timed instance.
Combines the success value from the current Maybe with the current time of
its reception, using the given Scheduler as time source,
then signals it as a Timed instance.
Returns an Observable that emits each item emitted by the current Observable, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler.
Returns an Observable that emits each item emitted by the current Observable, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler.
Combines the success value from the current Single with the current time (in milliseconds) of
its reception, using the computationScheduler as time source,
then signals them as a Timed instance.
Combines the success value from the current Single with the current time (in milliseconds) of
its reception, using the given Scheduler as time source,
then signals them as a Timed instance.
Combines the success value from the current Single with the current time of
its reception, using the computationScheduler as time source,
then signals it as a Timed instance.
Combines the success value from the current Single with the current time of
its reception, using the given Scheduler as time source,
then signals it as a Timed instance.
Returns a Single that emits a single HashMap containing all items emitted by the finite source Publisher,
mapped by the keys returned by a specified keySelector function.
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
finite source Publisher, mapped by the keys returned by a specified keySelector function.
Returns a Single that emits a single Map, returned by a specified mapFactory function, that
contains keys and values extracted from the items emitted by the finite source Publisher.
Returns a Single that emits a single HashMap containing all items emitted by the
current and finite Observable, mapped by the keys returned by a specified
keySelector function.
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
current and finite Observable, mapped by the keys and values returned by the given selector functions.
Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that
contains keys and values extracted from the items, via selector functions, emitted by the current and finite Observable.
Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the
finite source Publisher keyed by a specified keySelector function.
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified valueSelector function from items emitted by the finite source Publisher, keyed by a
specified keySelector function.
Returns a Single that emits a single Map, returned by a specified mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the finite source Publisher, and keyed by the keySelector function.
Returns a Single that emits a single Map, returned by a specified mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the finite source Publisher and keyed by the keySelector function.
Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the
current and finite Observable keyed by a specified keySelector function.
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified valueSelector function from items emitted by the current and finite Observable,
keyed by a specified keySelector function.
Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that
contains a custom Collection of values, extracted by a specified valueSelector function from
items emitted by the current and finite Observable, and keyed by the keySelector function.
Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the current and finite Observable and keyed by the keySelector function.
Converts this Completable into a Single which when this Completable completes normally,
calls the given Supplier and emits its returned value through onSuccess.
toSingle() - Method in class io.reactivex.rxjava3.core.Maybe
Converts this Maybe into a Single instance composing disposal
through and turning an empty Maybe into a signal of NoSuchElementException.
Returns a Single that emits a List that contains the items emitted by the finite source Publisher, in a
sorted order based on a specified comparison function.
Returns a Single that emits a List that contains the items emitted by the finite source Publisher, in a
sorted order based on a specified comparison function.
Returns a Single that emits a List that contains the items emitted by the current and finite Observable, in a
sorted order based on a specified comparison function.
Returns a Single that emits a List that contains the items emitted by the current and finite Observable, in a
sorted order based on a specified comparison function.
Returns a default, shared Scheduler instance whose Scheduler.Worker
instances queue work and execute them in a FIFO manner on one of the participating threads.
Attempts to emit the specified Throwable error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions.
Attempts to emit the specified Throwable error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions.
Attempts to emit the specified Throwable error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions.
Attempts to emit the specified Throwable error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions.
Attempts to emit the specified Throwable error if the downstream
hasn't cancelled the sequence or is otherwise terminated, returning false
if the emission is not allowed to happen due to lifecycle restrictions.
A FlowableProcessor variant that queues up events until a single Subscriber subscribes to it, replays
those events to it until the Subscriber catches up and then switches to relaying events live to
this single Subscriber until this UnicastProcessor terminates or the Subscriber cancels
its subscription.
A Subject that queues up events until a single Observer subscribes to it, replays
those events to it until the Observer catches up and then switches to relaying events live to
this single Observer until this UnicastSubject terminates or the Observer disposes.
unit() - Method in class io.reactivex.rxjava3.schedulers.Timed
Constructs a Completable instance by wrapping the given source callback
without any safeguards; you should manage the lifecycle and response
to downstream disposal.
Create a Flowable by wrapping a Publisherwhich has to be implemented according
to the Reactive Streams specification by handling backpressure and
cancellation correctly; no safeguards are provided by the Flowable itself.
Create an Observable by wrapping an ObservableSourcewhich has to be implemented according
to the Observable specification derived from the Reactive Streams specification by handling
disposal correctly; no safeguards are provided by the Observable itself.
Returns a Completable instance which manages a resource along
with a custom CompletableSource instance while the subscription is active and performs eager or lazy
resource disposition.
Constructs a Flowable that creates a dependent resource object, a Publisher with
that resource and calls the provided resourceDisposer function if this inner source terminates or the
downstream cancels the flow.
Constructs a Flowable that creates a dependent resource object, a Publisher with
that resource and calls the provided resourceDisposer function if this inner source terminates or the
downstream disposes the flow; doing it before these end-states have been reached if eager == true, after otherwise.
Constructs a Maybe that creates a dependent resource object which is disposed of when the
generated MaybeSource terminates or the downstream calls dispose().
Constructs a Maybe that creates a dependent resource object which is disposed first ({code eager == true})
when the generated MaybeSource terminates or the downstream disposes; or after ({code eager == false}).
Constructs an Observable that creates a dependent resource object, an ObservableSource with
that resource and calls the provided resourceDisposer function if this inner source terminates or the
downstream disposes the flow.
Constructs an Observable that creates a dependent resource object, an ObservableSource with
that resource and calls the provided disposer function if this inner source terminates or the
downstream disposes the flow; doing it before these end-states have been reached if eager == true, after otherwise.
Returns a Flowable that emits non-overlapping windows of items it collects from the current Flowable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Publisher.
Returns a Flowable that emits non-overlapping windows of items it collects from the current Flowable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Publisher.
Returns an Observable that emits non-overlapping windows of items it collects from the current Observable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
ObservableSource.
Returns an Observable that emits non-overlapping windows of items it collects from the current Observable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
ObservableSource.
Merges the specified Publisher into the current Flowable sequence by using the resultSelector
function only when the current Flowable (this instance) emits an item.
Merges the specified ObservableSource into the current Observable sequence by using the resultSelector
function only when the current Observable emits an item.
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSources via a function to produce the output item.
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSources via a function to produce the output item.
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSources via a function to produce the output item.
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSources via a function to produce the output item.
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSources via a function to produce the output item.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Publishers.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Publishers.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other MaybeSources.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other MaybeSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
Waits until all SingleSource sources provided by the Iterable sequence signal a success
value and calls a zipper function with an array of these values to return a result
to be emitted to the downstream.
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other Publishers.
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other MaybeSources.
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other ObservableSources.
Waits until all SingleSource sources provided via an array signal a success
value and calls a zipper function with an array of these values to return a result
to be emitted to downstream.
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and a specified Iterable sequence.
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and another specified Publisher.
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and another specified Publisher.
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and another specified Publisher.
Waits until this and the other MaybeSource signal a success value then applies the given BiFunction
to those values and emits the BiFunction's resulting value to downstream.
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Observable and a specified Iterable sequence.
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Observable and another specified ObservableSource.
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Observable and another specified ObservableSource.
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Observable and another specified ObservableSource.
Returns a Single that emits the result of applying a specified function to the pair of items emitted by
the current Single and another specified SingleSource.