Skip to content
This repository was archived by the owner on May 30, 2024. It is now read-only.

Commit 1a1e622

Browse files
prepare 5.0.1 release (#197)
1 parent 89e5bd1 commit 1a1e622

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/test/java/com/launchdarkly/sdk/server/StreamProcessorTest.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.junit.Before;
2727
import org.junit.Test;
2828

29+
import java.io.EOFException;
2930
import java.io.IOException;
3031
import java.net.URI;
3132
import java.time.Duration;
@@ -826,7 +827,9 @@ static class ConnectionErrorSink implements ConnectionErrorHandler {
826827
final BlockingQueue<Throwable> errors = new LinkedBlockingQueue<>();
827828

828829
public Action onConnectionError(Throwable t) {
829-
errors.add(t);
830+
if (!(t instanceof EOFException)) {
831+
errors.add(t);
832+
}
830833
return Action.SHUTDOWN;
831834
}
832835
}

0 commit comments

Comments
 (0)