public final Flux<T> timeout(Duration timeout, Scheduler timer) {
		return timeout(timeout, null, timer);
	}
public final Flux<T> timeout(Duration timeout, Scheduler timer) {
		return timeout(timeout, null, timer);
	}
public final Flux < T > timeout ( Duration timeout , Scheduler timer ) { return timeout ( timeout , null , timer ) ; }
Propagate a {@link TimeoutException} as soon as no item is emitted within the
given {@link Duration} from the previous emission (or the subscription for the first
item), as measured by the specified {@link Scheduler}.

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

@param timeout the timeout {@link Duration} between two signals from this {@link Flux}
@param timer a time-capable {@link Scheduler} instance to run on

@return a {@link Flux} that can time out on a per-item basis
Propagate a { @link TimeoutException } as soon as no item is emitted within the given { @link Duration } from the previous emission ( or the subscription for the first item ) as measured by the specified { @link Scheduler } .