code: public final Flux<Flux<T>> window(Publisher<?> boundary) {
  		return onAssembly(new FluxWindowBoundary<>(this,
  				boundary, Queues.unbounded(Queues.XS_BUFFER_SIZE)));
  	}
docs: 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}