code: public final ConnectableFlux<T> replay(Duration ttl, Scheduler timer) {
  		return replay(Integer.MAX_VALUE, ttl, timer);
  	}
docs: Turn this {@link Flux} into a connectable hot source and cache last emitted signals
  for further {@link Subscriber}. Will retain onNext signal for up to the given
  {@link Duration} with a per-item ttl.
  <p>
  Completion and Error will also be replayed until {@code ttl} triggers in which case
  the next {@link Subscriber} will start over a new subscription
  <p>
  <img class="marble" src="doc-files/marbles/replayWithTtl.svg" alt="">
  
  @param ttl Per-item and post termination timeout duration
  @param timer a time-capable {@link Scheduler} instance to read current time from
  
  @return a replaying {@link ConnectableFlux}