Skip to content

Commit 6ba7bcc

Browse files
retadk2k
authored andcommitted
Fix flaky terminaton conditions for org.opensearch.rest.ReactorNetty4StreamingStressIT.testCloseClientStreamingRequest test case (opensearch-project#15959)
Signed-off-by: Andriy Redko <andriy.redko@aiven.io>
1 parent c79e2f8 commit 6ba7bcc

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingStressIT.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88

99
package org.opensearch.rest;
1010

11+
import org.apache.hc.core5.http.ConnectionClosedException;
1112
import org.opensearch.client.Request;
1213
import org.opensearch.client.Response;
1314
import org.opensearch.client.StreamingRequest;
@@ -75,7 +76,7 @@ public void testCloseClientStreamingRequest() throws Exception {
7576
}
7677
})
7778
.then(() -> scheduler.advanceTimeBy(delay))
78-
.expectErrorMatches(t -> t instanceof InterruptedIOException)
79+
.expectErrorMatches(t -> t instanceof InterruptedIOException || t instanceof ConnectionClosedException)
7980
.verify();
8081
}
8182
}

0 commit comments

Comments
 (0)