reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<List<T>> buffer(Duration bufferingTimespan) {
		return buffer(bufferingTimespan, Schedulers.parallel());
	}
public final Flux<List<T>> buffer(Duration bufferingTimespan) {
		return buffer(bufferingTimespan, Schedulers.parallel());
	}
public final Flux < List < T > > buffer ( Duration bufferingTimespan ) { return buffer ( bufferingTimespan , Schedulers . parallel ( ) ) ; }
Collect incoming values into multiple {@link List} buffers that will be emitted by
the returned {@link Flux} every {@code bufferingTimespan}.
<p>
<img class="marble" src="doc-files/marbles/bufferWithTimespan.svg" alt="">

@reactor.discard This operator discards the currently open buffer upon cancellation or error triggered by a data signal.

@param bufferingTimespan the duration from buffer creation until a buffer is closed and emitted

@return a microbatched {@link Flux} of {@link List} delimited by the given time span
Collect incoming values into multiple { @link List } buffers that will be emitted by the returned { @link Flux } every { @code bufferingTimespan } . <p > <img class = marble src = doc - files / marbles / bufferWithTimespan . svg alt = >