code: public final ConnectableFlux<T> replay(int history, Duration ttl) {
  		return replay(history, ttl, Schedulers.parallel());
  	}
docs: Turn this {@link Flux} into a connectable hot source and cache last emitted signals
  for further {@link Subscriber}. Will retain up to the given history size onNext
  signals 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/replayWithHistoryAndTtl.svg" alt="">
  
  @param history number of events retained in history excluding complete and error
  @param ttl Per-item and post termination timeout duration
  
  @return a replaying {@link ConnectableFlux}