Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.functions | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.observable |
Modifier and Type | Method and Description |
---|---|
Flowable<Timed<T>> |
Flowable.timeInterval()
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
source Publisher.
|
Observable<Timed<T>> |
Observable.timeInterval()
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource.
|
Flowable<Timed<T>> |
Flowable.timeInterval(Scheduler scheduler)
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
source Publisher, where this interval is computed on a specified Scheduler.
|
Observable<Timed<T>> |
Observable.timeInterval(Scheduler scheduler)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource, where this interval is computed on a specified Scheduler.
|
Flowable<Timed<T>> |
Flowable.timeInterval(TimeUnit unit)
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
source Publisher.
|
Observable<Timed<T>> |
Observable.timeInterval(TimeUnit unit)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource.
|
Flowable<Timed<T>> |
Flowable.timeInterval(TimeUnit unit,
Scheduler scheduler)
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
source Publisher, where this interval is computed on a specified Scheduler.
|
Observable<Timed<T>> |
Observable.timeInterval(TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source ObservableSource, where this interval is computed on a specified Scheduler.
|
Flowable<Timed<T>> |
Flowable.timestamp()
Returns a Flowable that emits each item emitted by the source Publisher, wrapped in a
Timed object. |
Observable<Timed<T>> |
Observable.timestamp()
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object. |
Flowable<Timed<T>> |
Flowable.timestamp(Scheduler scheduler)
Returns a Flowable that emits each item emitted by the source Publisher, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler. |
Observable<Timed<T>> |
Observable.timestamp(Scheduler scheduler)
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler. |
Flowable<Timed<T>> |
Flowable.timestamp(TimeUnit unit)
Returns a Flowable that emits each item emitted by the source Publisher, wrapped in a
Timed object. |
Observable<Timed<T>> |
Observable.timestamp(TimeUnit unit)
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object. |
Flowable<Timed<T>> |
Flowable.timestamp(TimeUnit unit,
Scheduler scheduler)
Returns a Flowable that emits each item emitted by the source Publisher, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler. |
Observable<Timed<T>> |
Observable.timestamp(TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits each item emitted by the source ObservableSource, wrapped in a
Timed object whose timestamps are provided by a specified Scheduler. |
Modifier and Type | Method and Description |
---|---|
static <T> Function<T,Timed<T>> |
Functions.timestampWith(TimeUnit unit,
Scheduler scheduler) |
Modifier and Type | Method and Description |
---|---|
protected void |
FlowableTimeInterval.subscribeActual(org.reactivestreams.Subscriber<? super Timed<T>> s) |
Modifier and Type | Method and Description |
---|---|
void |
ObservableTimeInterval.subscribeActual(Observer<? super Timed<T>> t) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.