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 aFlowablethat emits records of the time interval between consecutive items emitted by the currentFlowable.Flowable.timeInterval(@NonNull Scheduler scheduler) Returns aFlowablethat 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 aFlowablethat emits records of the time interval between consecutive items emitted by the currentFlowable.Flowable.timeInterval(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowablethat 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 currentMaybeand 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 currentMaybeand 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 currentMaybeand 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 currentMaybeand signals it as a tuple (Timed) success value.final @NonNull Observable<Timed<T>> Observable.timeInterval()Returns anObservablethat emits records of the time interval between consecutive items emitted by the currentObservable.final @NonNull Observable<Timed<T>> Observable.timeInterval(@NonNull Scheduler scheduler) Returns anObservablethat 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 anObservablethat 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 anObservablethat 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 currentSingleand 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 currentSingleand 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 currentSingleand 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 currentSingleand signals it as a tuple (Timed) success value.Flowable.timestamp()Maybe.timestamp()final @NonNull Observable<Timed<T>> Observable.timestamp()Returns anObservablethat emits each item emitted by the currentObservable, wrapped in aTimedobject.final @NonNull Observable<Timed<T>> final @NonNull Observable<Timed<T>> Returns anObservablethat emits each item emitted by the currentObservable, wrapped in aTimedobject.final @NonNull Observable<Timed<T>> Single.timestamp() -
Uses of Timed in io.reactivex.rxjava3.internal.functions
Classes in io.reactivex.rxjava3.internal.functions that implement interfaces with type arguments of type TimedModifier and TypeClassDescription(package private) static final classMethods 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
Subclasses with type arguments of type Timed in io.reactivex.rxjava3.internal.operators.flowableFields 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 voidFlowableTimeInterval.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
Subclasses with type arguments of type Timed in io.reactivex.rxjava3.internal.operators.maybeModifier and TypeClassDescriptionfinal classMeasures the time between subscription and the success item emission from the upstream and emits this as aTimedsuccess value.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.downstreamMethod parameters in io.reactivex.rxjava3.internal.operators.maybe with type arguments of type TimedModifier and TypeMethodDescriptionprotected voidMaybeTimeInterval.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
Subclasses with type arguments of type Timed in io.reactivex.rxjava3.internal.operators.observableFields 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 TypeMethodDescriptionvoidObservableTimeInterval.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
Subclasses with type arguments of type Timed in io.reactivex.rxjava3.internal.operators.singleModifier and TypeClassDescriptionfinal classMeasures the time between subscription and the success item emission from the upstream and emits this as aTimedsuccess value.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.downstreamMethod parameters in io.reactivex.rxjava3.internal.operators.single with type arguments of type TimedModifier and TypeMethodDescriptionprotected voidSingleTimeInterval.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)