reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<Flux<T>> window(Publisher<?> boundary) {
		return onAssembly(new FluxWindowBoundary<>(this,
				boundary, Queues.unbounded(Queues.XS_BUFFER_SIZE)));
	}
public final Flux<Flux<T>> window(Publisher<?> boundary) {
		return onAssembly(new FluxWindowBoundary<>(this,
				boundary, Queues.unbounded(Queues.XS_BUFFER_SIZE)));
	}
Split this {@link Flux} sequence into continuous, non-overlapping windows
where the window boundary is signalled by another {@link Publisher}

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

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

@param boundary a {@link Publisher} to emit any item for a split signal and complete to terminate

@return a {@link Flux} of {@link Flux} windows delimited by a given {@link Publisher}