Skip to content

Commit 988bda1

Browse files
committed
re-interrupt
1 parent 59af044 commit 988bda1

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

client/src/main/java/io/split/engine/sse/client/SSEClient.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ public synchronized boolean open(URI uri) {
7272
try {
7373
signal.await(CONNECT_TIMEOUT, TimeUnit.SECONDS);
7474
} catch (InterruptedException e) {
75+
Thread.currentThread().interrupt();
7576
_log.warn(e.getMessage());
7677
return false;
7778
}

client/src/test/java/io/split/client/SplitClientIntegrationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -543,7 +543,7 @@ public void testConnectionClosedIsProperlyHandled() throws IOException, TimeoutE
543543
result = client.getTreatment("admin", "push_test");
544544
Assert.assertEquals("on_whitelist", result);
545545
}
546-
546+
547547
private SSEMockServer buildSSEMockServer(SSEMockServer.SseEventQueue eventQueue) {
548548
return new SSEMockServer(eventQueue, (token, version, channel) -> {
549549
if (!"1.1".equals(version)) {

0 commit comments

Comments
 (0)