Fix flaky ReactorNetty4StreamingStressIT (opensearch-project#18008)

reta · Harsh Kothari · commit 7571c2853646 · 2025-05-07T12:39:26.000+05:30
Signed-off-by: Andriy Redko &lt;drreta@gmail.com&gt;
Signed-off-by: Harsh Kothari &lt;techarsh@amazon.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`	`}`