public static <T> TimeLimiterOperator<T> of(TimeLimiter timeLimiter) {
        return new TimeLimiterOperator<>(timeLimiter);
    }
@Test
    public void doNotTimeoutUsingFlux() {
        given(timeLimiter.getTimeLimiterConfig())
            .willReturn(toConfig(Duration.ofMinutes(1)));

        Flux<?> flux = Flux.interval(Duration.ofMillis(1), Schedulers.single())
            .take(2)
            .transformDeferred(TimeLimiterOperator.of(timeLimiter));

        StepVerifier.create(flux)
            .expectNextCount(2)
            .verifyComplete();
        then(timeLimiter).should(times(3))
            .onSuccess();
    }