File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
rxjava-core/src/main/java/rx Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change 64
64
import rx .operators .OperationTakeLast ;
65
65
import rx .operators .OperationTakeUntil ;
66
66
import rx .operators .OperationTakeWhile ;
67
+ import rx .operators .OperationTimestamp ;
67
68
import rx .operators .OperationToFuture ;
68
69
import rx .operators .OperationToIterator ;
69
70
import rx .operators .OperationToObservableFuture ;
@@ -2093,6 +2094,14 @@ public Boolean call(T t, Integer integer)
2093
2094
}));
2094
2095
}
2095
2096
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
+
2096
2105
/**
2097
2106
* Return a Future representing a single value of the Observable.
2098
2107
* <p>
You can’t perform that action at this time.
0 commit comments