public final <U> Flux<T> sampleTimeout(Function<? super T, ? extends Publisher<U>>
			throttlerFactory, int maxConcurrency) {
		return onAssembly(new FluxSampleTimeout<>(this, throttlerFactory,
				Queues.get(maxConcurrency)));
	}
public final <U> Flux<T> sampleTimeout(Function<? super T, ? extends Publisher<U>>
			throttlerFactory, int maxConcurrency) {
		return onAssembly(new FluxSampleTimeout<>(this, throttlerFactory,
				Queues.get(maxConcurrency)));
	}
public final < U > Flux < T > sampleTimeout ( Function < ? super T , ? extends Publisher < U > > throttlerFactory , int maxConcurrency ) { return onAssembly ( new FluxSampleTimeout <> ( this , throttlerFactory , Queues . get ( maxConcurrency ) ) ) ; }
FIXME re-evaluate the wording on maxConcurrency, seems more related to request/buffering. If so redo the marble
FIXME re - evaluate the wording on maxConcurrency seems more related to request / buffering . If so redo the marble