diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxWindowTimeout.java b/reactor-core/src/main/java/reactor/core/publisher/FluxWindowTimeout.java
index <HASH>..<HASH> 100644
--- a/reactor-core/src/main/java/reactor/core/publisher/FluxWindowTimeout.java
+++ b/reactor-core/src/main/java/reactor/core/publisher/FluxWindowTimeout.java
@@ -1008,7 +1008,10 @@ final class FluxWindowTimeout<T> extends InternalFluxOperator<T, Flux<T>> {
 		}
 
 		boolean sendNext(T t) {
-			int received = this.received + 1 ;
+			final int received = this.received + 1 ;
+			if (received > this.max) {
+				return false;
+			}
 			this.received = received;
 
 			this.queue.offer(t);
@@ -1399,10 +1402,6 @@ final class FluxWindowTimeout<T> extends InternalFluxOperator<T, Flux<T>> {
 			}
 		}
 
-		static boolean isCancelledBySubscriberOrByParent(long state) {
-			return (state & CANCELLED_STATE) == CANCELLED_STATE  || (state & PARENT_CANCELLED_STATE) == PARENT_CANCELLED_STATE;
-		}
-
 		static boolean isCancelled(long state) {
 			return (state & CANCELLED_STATE) == CANCELLED_STATE;
 		}
Add windowTimeout sendNext early guard against maxSize overflow (#<I>)

This commit improves the  InnerWindow.sendNext method to guard against

attempts at sending more than the window's maxSize elements, earlier in

the codepath.



It also removes an unused method that was left-in during iterations on

the backpressure-aware new implementation from #<I>.