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>

Methods

timestamp() → Stream<Timestamped<T>>

Available on Stream<T>, provided by the TimeStampExtension extension

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.