code: public final Flux<T> timeout(Duration timeout, Scheduler timer) {
  		return timeout(timeout, null, timer);
  	}
docs: Propagate a {@link TimeoutException} as soon as no item is emitted within the
  given {@link Duration} from the previous emission (or the subscription for the first
  item), as measured by the specified {@link Scheduler}.
  
  <p>
  <img class="marble" src="doc-files/marbles/timeoutForFlux.svg" alt="">
  
  @param timeout the timeout {@link Duration} between two signals from this {@link Flux}
  @param timer a time-capable {@link Scheduler} instance to run on
  
  @return a {@link Flux} that can time out on a per-item basis