Uses of Annotation Interface
io.reactivex.rxjava3.annotations.Experimental
Packages that use Experimental
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of Experimental in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with annotations of type ExperimentalModifier and TypeMethodDescriptionFlowable.debounce
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.debounce
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.Flowable.onBackpressureBuffer
(int capacity, boolean delayError, boolean unbounded, @NonNull Action onOverflow, @NonNull Consumer<? super @NonNull T> onDropped) Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.Flowable.onBackpressureBuffer
(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy, @NonNull Consumer<? super @NonNull T> onDropped) Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.Flowable.onBackpressureLatest
(@NonNull Consumer<? super @NonNull T> onDropped) Drops all but the latest item emitted by the currentFlowable
if the downstream is not ready to receive new items (indicated by a lack ofSubscription.request(long)
calls from it) and emits this latest item when the downstream becomes ready.Flowable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits the most recently emitted item (if any) emitted by the currentFlowable
within periodic time intervals, where the intervals are defined on a particularScheduler
and optionally emit the very last upstream item when the upstream completes.final @NonNull Observable
<T> Observable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals, where the intervals are defined on a particularScheduler
.Flowable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits only the first item emitted by the currentFlowable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits only the first item emitted by the currentObservable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.Flowable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits only the last item emitted by the currentFlowable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits only the last item emitted by the currentObservable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.Flowable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Throttles items from the upstreamFlowable
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.final @NonNull Observable
<T> Observable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Throttles items from the currentObservable
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.Flowable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.