reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<Flux<T>> window(Duration windowingTimespan) {
		return window(windowingTimespan, Schedulers.parallel());
	}
public final Flux<Flux<T>> window(Duration windowingTimespan) {
		return window(windowingTimespan, Schedulers.parallel());
	}
Split this {@link Flux} sequence into continuous, non-overlapping windows that open
for a {@code windowingTimespan} {@link Duration} (as measured on the {@link Schedulers#parallel() parallel}
Scheduler).

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

@reactor.discard This operator discards elements it internally queued for backpressure
upon cancellation or error triggered by a data signal.

@param windowingTimespan the {@link Duration} to delimit {@link Flux} windows

@return a {@link Flux} of {@link Flux} windows continuously opened for a given {@link Duration}