Removed TODO

reactor · Jun 6, 2023 · 8cc7404 · 8cc7404
1 parent befec06
commit 8cc7404
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/Flux.java b/reactor-core/src/main/java/reactor/core/publisher/Flux.java
@@ -3134,8 +3134,6 @@ public final  <C extends Collection<? super T>> Flux<C> bufferTimeout(int maxSiz
 
 	public final  <C extends Collection<? super T>> Flux<C> bufferTimeout(int maxSize, Duration maxTime,
 			Scheduler timer, Supplier<C> bufferSupplier, boolean fairBackpressure) {
-		// TODO: if maxSize == Integer.MAX_VALUE -> return plain buffer() with timeout
-		//  as parameter for time.
 		return onAssembly(new FluxBufferTimeout<>(this, maxSize, maxTime.toNanos(), TimeUnit.NANOSECONDS, timer, bufferSupplier,
 				fairBackpressure));
 	}