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);
		}
	}
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
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 ) .