reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<T> onBackpressureBuffer(Duration ttl, int maxSize, Consumer<? super T> onBufferEviction) {
		return onBackpressureBuffer(ttl, maxSize, onBufferEviction, Schedulers.parallel());
	}
public final Flux<T> onBackpressureBuffer(Duration ttl, int maxSize, Consumer<? super T> onBufferEviction) {
		return onBackpressureBuffer(ttl, maxSize, onBufferEviction, Schedulers.parallel());
	}
public final Flux < T > onBackpressureBuffer ( Duration ttl , int maxSize , Consumer < ? super T > onBufferEviction ) { return onBackpressureBuffer ( ttl , maxSize , onBufferEviction , Schedulers . parallel ( ) ) ; }
Request an unbounded demand and push to the returned {@link Flux}, or park the observed
elements if not enough demand is requested downstream, within a {@code maxSize}
limit and for a maximum {@link Duration} of {@code ttl} (as measured on the
{@link Schedulers#elastic() elastic Scheduler}). Over that limit, oldest
elements from the source are dropped.
<p>
Elements evicted based on the TTL are passed to a cleanup {@link Consumer}, which
is also immediately invoked when there is an overflow.

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

@reactor.discard This operator discards its internal buffer of elements that overflow,
after having applied the {@code onBufferEviction} handler.

@param ttl maximum {@link Duration} for which an element is kept in the backlog
@param maxSize maximum buffer backlog size before overflow callback is called
@param onBufferEviction callback to invoke once TTL is reached or on overflow

@return a backpressured {@link Flux} that buffers with a TTL and up to a capacity then applies an
overflow strategy
Request an unbounded demand and push to the returned { @link Flux } or park the observed elements if not enough demand is requested downstream within a { @code maxSize } limit and for a maximum { @link Duration } of { @code ttl } ( as measured on the { @link Schedulers#elastic () elastic Scheduler } ) . Over that limit oldest elements from the source are dropped . <p > Elements evicted based on the TTL are passed to a cleanup { @link Consumer } which is also immediately invoked when there is an overflow .