code: public final <U> Flux<T> sampleTimeout(Function<? super T, ? extends Publisher<U>> throttlerFactory) {
  		return sampleTimeout(throttlerFactory, Queues.XS_BUFFER_SIZE);
  	}
docs: Emit the latest value from this {@link Flux} only if there were no new values emitted
  during the window defined by a companion {@link Publisher} derived from that particular
  value.
  <p>
  Note that this means that the last value in the sequence is always emitted.
  
  <p>
  <img class="marble" src="doc-files/marbles/sampleTimeoutWithThrottlerFactory.svg" alt="">
  
  @reactor.discard This operator discards elements that are not part of the sampling.
  
  @param throttlerFactory supply a companion sampler {@link Publisher} which signals
  the end of the window during which no new emission should occur. If it is the case,
  the original value triggering the window is emitted.
  @param <U> the companion reified type
  
  @return a {@link Flux} sampled to items not followed by any other item within a window
  defined by a companion {@link Publisher}