Fix flaky ReactorNetty4StreamingStressIT (#18008)

reta · web-flow · commit 473665fa1c8a · 2025-04-20T09:02:29.000-04:00
Signed-off-by: Andriy Redko &lt;drreta@gmail.com&gt;
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
@@ -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));
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -77,6 +77,6 @@ public void testCloseClientStreamingRequest() throws Exception {`
`77`	`77`	`})`
`78`	`78`	`.then(() -> scheduler.advanceTimeBy(delay))`
`79`	`79`	`.expectErrorMatches(t -> t instanceof InterruptedIOException \|\| t instanceof ConnectionClosedException)`
`80`		`- .verify();`
	`80`	`+ .verify(Duration.ofSeconds(10));`
`81`	`81`	`}`
`82`	`82`	`}`