reactor-core/src/main/java/reactor/core/publisher/Flux.java
public final Flux<T> take(Duration timespan, Scheduler timer) {
		if (!timespan.isZero()) {
			return takeUntilOther(Mono.delay(timespan, timer));
		}
		else {
			return take(0);
		}
	}
public final Flux<T> take(Duration timespan, Scheduler timer) {
		if (!timespan.isZero()) {
			return takeUntilOther(Mono.delay(timespan, timer));
		}
		else {
			return take(0);
		}
	}
Relay values from this {@link Flux} until the specified {@link Duration} elapses,
as measured on the specified {@link Scheduler}.
<p>
If the duration is zero, the resulting {@link Flux} completes as soon as this {@link Flux}
signals its first value (which is not not relayed, though).

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

@param timespan the {@link Duration} of the time window during which to emit elements
from this {@link Flux}
@param timer a time-capable {@link Scheduler} instance to run on

@return a {@link Flux} limited to elements emitted within a specific duration