Fix bug in SseEventSourceImpl.EventHandler, which is not calling coun…

…tDown on connectedLatch, causing useless delays
resteasy · Apr 21, 2017 · c8ecb24 · c8ecb24
1 parent e372882
commit c8ecb24
Showing 1 changed file with 10 additions and 5 deletions.
diff --git a/providers/sse/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseEventSourceImpl.java b/providers/sse/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseEventSourceImpl.java
@@ -250,11 +250,16 @@ private EventHandler(final EventHandler anotherHandler)
       public void run()
       {
          SseEventInput eventInput = null;
-         final Invocation.Builder request = buildRequest();
-         if (state.get() == State.OPEN)
-         {
-            eventInput = request.get(SseEventInput.class);
-
+         try {
+            final Invocation.Builder request = buildRequest();
+            if (state.get() == State.OPEN)
+            {
+               eventInput = request.get(SseEventInput.class);
+            }
+         } finally {
+            if (connectedLatch != null) {
+               connectedLatch.countDown();
+            }
          }
          while (state.get() == State.OPEN)
          {