Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
Modifier and Type | Method and Description |
---|---|
Observable<Timestamped<T>> |
Observable.timestamp()
Returns an Observable that emits each item emitted by the source Observable, wrapped in a
Timestamped object. |
Observable<Timestamped<T>> |
Observable.timestamp(Scheduler scheduler)
Returns an Observable that emits each item emitted by the source Observable, wrapped in a
Timestamped object whose timestamps are provided by a specified Scheduler. |
Modifier and Type | Method and Description |
---|---|
Subscriber<? super T> |
OperatorTimestamp.call(Subscriber<? super Timestamped<T>> o) |
Copyright © 2017. All rights reserved.