Uses of Class
io.reactivex.rxjava3.schedulers.Timed
Packages that use Timed
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of Timed in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return types with arguments of type TimedModifier and TypeMethodDescriptionFlowable.timeInterval()
Returns aFlowable
that emits records of the time interval between consecutive items emitted by the currentFlowable
.Flowable.timeInterval
(@NonNull Scheduler scheduler) Returns aFlowable
that emits records of the time interval between consecutive items emitted by the currentFlowable
, where this interval is computed on a specifiedScheduler
.Flowable.timeInterval
(@NonNull TimeUnit unit) Returns aFlowable
that emits records of the time interval between consecutive items emitted by the currentFlowable
.Flowable.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits records of the time interval between consecutive items emitted by the currentFlowable
, where this interval is computed on a specifiedScheduler
.Maybe.timeInterval()
Measures the time (in milliseconds) between the subscription and success item emission of the currentMaybe
and signals it as a tuple (Timed
) success value.Maybe.timeInterval
(@NonNull Scheduler scheduler) Measures the time (in milliseconds) between the subscription and success item emission of the currentMaybe
and signals it as a tuple (Timed
) success value.Maybe.timeInterval
(@NonNull TimeUnit unit) Measures the time between the subscription and success item emission of the currentMaybe
and signals it as a tuple (Timed
) success value.Maybe.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Measures the time between the subscription and success item emission of the currentMaybe
and signals it as a tuple (Timed
) success value.final @NonNull Observable
<Timed<T>> Observable.timeInterval()
Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
.final @NonNull Observable
<Timed<T>> Observable.timeInterval
(@NonNull Scheduler scheduler) Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
, where this interval is computed on a specifiedScheduler
.final @NonNull Observable
<Timed<T>> Observable.timeInterval
(@NonNull TimeUnit unit) Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
.final @NonNull Observable
<Timed<T>> Observable.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
, where this interval is computed on a specifiedScheduler
.Single.timeInterval()
Measures the time (in milliseconds) between the subscription and success item emission of the currentSingle
and signals it as a tuple (Timed
) success value.Single.timeInterval
(@NonNull Scheduler scheduler) Measures the time (in milliseconds) between the subscription and success item emission of the currentSingle
and signals it as a tuple (Timed
) success value.Single.timeInterval
(@NonNull TimeUnit unit) Measures the time between the subscription and success item emission of the currentSingle
and signals it as a tuple (Timed
) success value.Single.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Measures the time between the subscription and success item emission of the currentSingle
and signals it as a tuple (Timed
) success value.Flowable.timestamp()
Maybe.timestamp()
final @NonNull Observable
<Timed<T>> Observable.timestamp()
Returns anObservable
that emits each item emitted by the currentObservable
, wrapped in aTimed
object.final @NonNull Observable
<Timed<T>> final @NonNull Observable
<Timed<T>> Returns anObservable
that emits each item emitted by the currentObservable
, wrapped in aTimed
object.final @NonNull Observable
<Timed<T>> Single.timestamp()
-
Uses of Timed in io.reactivex.rxjava3.internal.functions
Methods in io.reactivex.rxjava3.internal.functions that return TimedMethods in io.reactivex.rxjava3.internal.functions that return types with arguments of type Timed -
Uses of Timed in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type TimedMethod parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type TimedModifier and TypeMethodDescriptionprotected void
FlowableTimeInterval.subscribeActual
(org.reactivestreams.Subscriber<? super Timed<T>> s) Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type TimedModifierConstructorDescription(package private)
TimeIntervalSubscriber
(org.reactivestreams.Subscriber<? super Timed<T>> actual, TimeUnit unit, Scheduler scheduler) -
Uses of Timed in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe with type parameters of type TimedModifier and TypeFieldDescription(package private) final MaybeObserver
<? super Timed<T>> MaybeTimeInterval.TimeIntervalMaybeObserver.downstream
Method parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type TimedModifier and TypeMethodDescriptionprotected void
MaybeTimeInterval.subscribeActual
(@NonNull MaybeObserver<? super @NonNull Timed<T>> observer) Constructor parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type TimedModifierConstructorDescription(package private)
TimeIntervalMaybeObserver
(MaybeObserver<? super Timed<T>> downstream, TimeUnit unit, Scheduler scheduler, boolean start) -
Uses of Timed in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type TimedMethod parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type TimedModifier and TypeMethodDescriptionvoid
ObservableTimeInterval.subscribeActual
(Observer<? super Timed<T>> t) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type Timed -
Uses of Timed in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single with type parameters of type TimedModifier and TypeFieldDescription(package private) final SingleObserver
<? super Timed<T>> SingleTimeInterval.TimeIntervalSingleObserver.downstream
Method parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type TimedModifier and TypeMethodDescriptionprotected void
SingleTimeInterval.subscribeActual
(@NonNull SingleObserver<? super @NonNull Timed<T>> observer) Constructor parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type TimedModifierConstructorDescription(package private)
TimeIntervalSingleObserver
(SingleObserver<? super Timed<T>> downstream, TimeUnit unit, Scheduler scheduler, boolean start)