diff --git a/build.gradle b/build.gradle index a1e09f426..9c6e53740 100644 --- a/build.gradle +++ b/build.gradle @@ -73,7 +73,7 @@ ext.versions = [ "guava": "28.2-jre", "jackson": "2.10.0", "launchdarklyJavaSdkCommon": "1.0.0", - "okhttpEventsource": "2.3.0", + "okhttpEventsource": "2.3.1", "slf4j": "1.7.21", "snakeyaml": "1.19", "jedis": "2.9.0" diff --git a/src/test/java/com/launchdarkly/sdk/server/StreamProcessorTest.java b/src/test/java/com/launchdarkly/sdk/server/StreamProcessorTest.java index 200cd34d6..7ead898fc 100644 --- a/src/test/java/com/launchdarkly/sdk/server/StreamProcessorTest.java +++ b/src/test/java/com/launchdarkly/sdk/server/StreamProcessorTest.java @@ -26,6 +26,7 @@ import org.junit.Before; import org.junit.Test; +import java.io.EOFException; import java.io.IOException; import java.net.URI; import java.time.Duration; @@ -826,7 +827,9 @@ static class ConnectionErrorSink implements ConnectionErrorHandler { final BlockingQueue errors = new LinkedBlockingQueue<>(); public Action onConnectionError(Throwable t) { - errors.add(t); + if (!(t instanceof EOFException)) { + errors.add(t); + } return Action.SHUTDOWN; } }