Skip to content

Commit cd0829f

Browse files
committed
Improve stability
1 parent 505e38a commit cd0829f

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/test/java/org/java_websocket/issues/Issue677Test.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -117,6 +117,13 @@ public void onStart() {
117117
assertTrue(webSocket0.isOpen(), "webSocket.isOpen()");
118118
webSocket0.close();
119119
countDownLatch0.await();
120+
// Add some delay is since the latch will be decreased in the onClose before the state is reset
121+
for (int i = 0; i < 5; i++) {
122+
if (webSocket0.isClosed()) {
123+
break;
124+
}
125+
Thread.sleep(5);
126+
}
120127
assertTrue(webSocket0.isClosed(), "webSocket.isClosed()");
121128
webSocket1.connectBlocking();
122129
assertTrue(webSocket1.isOpen(), "webSocket.isOpen()");

0 commit comments

Comments
 (0)