@NonNull Flowable<T> |
Flowable.debounce(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Observable<T> |
Observable.debounce(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Flowable<T> |
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 current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
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 current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureLatest(@NonNull Consumer<? super @NonNull T> onDropped) |
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.
|
@NonNull Flowable<T> |
Flowable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast,
@NonNull Consumer<? super @NonNull T> onDropped) |
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.
|
@NonNull Observable<T> |
Observable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Flowable<T> |
Flowable.throttleFirst(long skipDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Observable<T> |
Observable.throttleFirst(long skipDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Flowable<T> |
Flowable.throttleLast(long intervalDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Observable<T> |
Observable.throttleLast(long intervalDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Flowable<T> |
Flowable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast,
@NonNull Consumer<? super @NonNull T> onDropped) |
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.
|
@NonNull Observable<T> |
Observable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast,
@NonNull Consumer<? super @NonNull T> onDropped) |
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.
|
@NonNull Flowable<T> |
Flowable.throttleWithTimeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|
@NonNull Observable<T> |
Observable.throttleWithTimeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
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 .
|