Eternity.Timestamped.Potoki.Transform

Documentation

timestamp :: Transform event (Timestamped event)

Useful for getting a Consume, which timestamps the events automatically as they arrive.

E.g., you can apply it to writeToDir:

transform timestamp . writeToDir :: FilePath -> Consume event (Either IOException ())