public final Flux<Flux<T>> window(int maxSize) {
		return onAssembly(new FluxWindow<>(this, maxSize, Queues.get(maxSize)));
	}
public final Flux<Flux<T>> window(int maxSize) {
		return onAssembly(new FluxWindow<>(this, maxSize, Queues.get(maxSize)));
	}
public final Flux < Flux < T > > window ( int maxSize ) { return onAssembly ( new FluxWindow <> ( this , maxSize , Queues . get ( maxSize ) ) ) ; }
Split this {@link Flux} sequence into multiple {@link Flux} windows containing
{@code maxSize} elements (or less for the final window) and starting from the first item.
Each {@link Flux} window will onComplete after {@code maxSize} items have been routed.

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

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

@param maxSize the maximum number of items to emit in the window before closing it

@return a {@link Flux} of {@link Flux} windows based on element count
Split this { @link Flux } sequence into multiple { @link Flux } windows containing { @code maxSize } elements ( or less for the final window ) and starting from the first item . Each { @link Flux } window will onComplete after { @code maxSize } items have been routed .