timestamp method

Stream<Timestamped<T>> timestamp ()

Wraps each item emitted by the source Stream in a Timestamped object that includes the emitted item and the time when the item was emitted.

Example

Stream.fromIterable([1])
   .timestamp()
   .listen((i) => print(i)); // prints 'TimeStamp{timestamp: XXX, value: 1}';

Implementation

Stream<Timestamped<T>> timestamp() =>
    transform(TimestampStreamTransformer<T>());