Skip to content

Commit 79867fb

Browse files
authored
Fix flaky terminaton conditions for org.opensearch.rest.ReactorNetty4StreamingStressIT.testCloseClientStreamingRequest test case (#15959) (#15962)
Signed-off-by: Andriy Redko <[email protected]> (cherry picked from commit eb5b703)
1 parent bfdc30c commit 79867fb

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
@@ -17,6 +17,7 @@
1717
import org.junit.After;
1818

1919
import java.io.IOException;
20+
import java.io.InterruptedIOException;
2021
import java.io.UncheckedIOException;
2122
import java.nio.ByteBuffer;
2223
import java.nio.charset.StandardCharsets;
@@ -75,7 +76,7 @@ public void testCloseClientStreamingRequest() throws Exception {
7576
}
7677
})
7778
.then(() -> scheduler.advanceTimeBy(delay))
78-
.expectErrorMatches(t -> t instanceof ConnectionClosedException)
79+
.expectErrorMatches(t -> t instanceof InterruptedIOException || t instanceof ConnectionClosedException)
7980
.verify();
8081
}
8182
}

0 commit comments

Comments
 (0)