reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<T> timeout(Duration timeout) {
		return timeout(timeout, null, Schedulers.parallel());
	}
public final Flux<T> timeout(Duration timeout) {
		return timeout(timeout, null, Schedulers.parallel());
	}
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).

<p>
<img class="marble" src="doc-files/marbles/timeoutForFlux.svg" alt="">

@param timeout the timeout between two signals from this {@link Flux}

@return a {@link Flux} that can time out on a per-item basis