Skip to content

Commit 9427266

Browse files
author
jmhofer
committed
Merged with master from Netflix repo.
1 parent f082889 commit 9427266

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

rxjava-core/src/main/java/rx/Observable.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@
6464
import rx.operators.OperationTakeLast;
6565
import rx.operators.OperationTakeUntil;
6666
import rx.operators.OperationTakeWhile;
67+
import rx.operators.OperationTimestamp;
6768
import rx.operators.OperationToFuture;
6869
import rx.operators.OperationToIterator;
6970
import rx.operators.OperationToObservableFuture;
@@ -2093,6 +2094,14 @@ public Boolean call(T t, Integer integer)
20932094
}));
20942095
}
20952096

2097+
/**
2098+
* Adds a timestamp to each item emitted by this observable.
2099+
* @return An observable sequence of timestamped items.
2100+
*/
2101+
public Observable<Timestamped<T>> timestamp() {
2102+
return create(OperationTimestamp.timestamp(this));
2103+
}
2104+
20962105
/**
20972106
* Return a Future representing a single value of the Observable.
20982107
* <p>

0 commit comments

Comments
 (0)