TimeStampExtension<T> extension
Extends the Stream class with the ability to wrap each item emitted by the source Stream in a Timestamped object that includes the emitted item and the time when the item was emitted.
- on
-
- Stream<
T>
- Stream<
Methods
-
timestamp(
) → Stream< Timestamped< T> > - 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.