| /** PURE_IMPORTS_START .._scheduler_async,._map PURE_IMPORTS_END */ |
| import { async } from '../scheduler/async'; |
| import { map } from './map'; |
| /** |
| * @param scheduler |
| * @return {Observable<Timestamp<any>>|WebSocketSubject<T>|Observable<T>} |
| * @method timestamp |
| * @owner Observable |
| */ |
| export function timestamp(scheduler) { |
| if (scheduler === void 0) { |
| scheduler = async; |
| } |
| return map(function (value) { return new Timestamp(value, scheduler.now()); }); |
| // return (source: Observable<T>) => source.lift(new TimestampOperator(scheduler)); |
| } |
| export var Timestamp = /*@__PURE__*/ (/*@__PURE__*/ function () { |
| function Timestamp(value, timestamp) { |
| this.value = value; |
| this.timestamp = timestamp; |
| } |
| return Timestamp; |
| }()); |
| ; |
| //# sourceMappingURL=timestamp.js.map |
