restore missing returns

mredolatti · mredolatti · commit 9aeebbeeb967 · 2020-09-04T10:55:52.000-03:00
diff --git a/client/src/main/java/io/split/engine/sse/client/SSEClient.java b/client/src/main/java/io/split/engine/sse/client/SSEClient.java
@@ -118,9 +118,11 @@ private void connectAndLoop(URI uri, CountDownLatch signal) {
                     }
                     // Connection closed by server
                     _statusCallback.apply(StatusMessage.RETRYABLE_ERROR);
+                    return;
                 } catch (IOException exc) { // Other type of connection error
                     _log.warn(exc.getMessage());
                     _statusCallback.apply(StatusMessage.RETRYABLE_ERROR);
+                    return;
                 }
             }
         } catch (Exception e) { // Any other error non related to the connection disables streaming altogether

Original file line number	Diff line number	Diff line change
`@@ -118,9 +118,11 @@ private void connectAndLoop(URI uri, CountDownLatch signal) {`
`118`	`118`	`}`
`119`	`119`	`// Connection closed by server`
`120`	`120`	`_statusCallback.apply(StatusMessage.RETRYABLE_ERROR);`
	`121`	`+ return;`
`121`	`122`	`} catch (IOException exc) { // Other type of connection error`
`122`	`123`	`_log.warn(exc.getMessage());`
`123`	`124`	`_statusCallback.apply(StatusMessage.RETRYABLE_ERROR);`
	`125`	`+ return;`
`124`	`126`	`}`
`125`	`127`	`}`
`126`	`128`	`} catch (Exception e) { // Any other error non related to the connection disables streaming altogether`