diff --git a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java b/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java index 4ac4ccb..1c9e35e 100644 --- a/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java +++ b/src/main/java/com/mgabriel/chronicle/flux/replay/ReplayFlux.java @@ -49,6 +49,7 @@ public class ReplayFlux extends Flux implements Scannable { } /** + * @param acceleration time acceleration * @return a flux that will replay the values with a time acceleration applied to their original timing * (e.g. if the values were received with a 2 second interval, and the time acceleration is 2, then the returned flux will emit at a 1 second interval). */