From 5e4928d8e0f3bdc5cba7bdc2b505a2da5e4f0edb Mon Sep 17 00:00:00 2001
From: Andriy Redko <drreta@gmail.com>
Date: Fri, 18 Apr 2025 17:01:11 -0400
Subject: [PATCH] Fix flaky ReactorNetty4StreamingStressIT

Signed-off-by: Andriy Redko <drreta@gmail.com>
---
 .../org/opensearch/rest/ReactorNetty4StreamingStressIT.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingStressIT.java b/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingStressIT.java
index 9da456f618ffc..d4696d82c13e7 100644
--- a/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingStressIT.java
+++ b/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingStressIT.java
@@ -77,6 +77,6 @@ public void testCloseClientStreamingRequest() throws Exception {
             })
             .then(() -> scheduler.advanceTimeBy(delay))
             .expectErrorMatches(t -> t instanceof InterruptedIOException || t instanceof ConnectionClosedException)
-            .verify();
+            .verify(Duration.ofSeconds(10));
     }
 }