[RESTEASY-1680]:Close all subscribed SseEventSink instances when clos…

…e SseBroadCaster
resteasy · Jan 15, 2018 · 42a76bf · 42a76bf
1 parent 50f15af
commit 42a76bf
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...easy-jaxrs/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseBroadcasterImpl.java b/...easy-jaxrs/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseBroadcasterImpl.java
@@ -5,7 +5,6 @@
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.TimeUnit;
 import java.util.function.BiConsumer;
 import java.util.function.Consumer;
 
@@ -26,7 +25,9 @@ public SseBroadcasterImpl () {
    @Override
    public void close()
    {
-      outputQueue.forEach(evenSink -> {closeConsumers.forEach(consumer-> {consumer.accept(evenSink);});});
+      //Javadoc says close the broadcaster and all subscribed {@link SseEventSink} instances.
+      //is it necessay to close the subsribed SseEventSink ?
+      outputQueue.forEach(evenSink -> {evenSink.close(); closeConsumers.forEach(consumer-> {consumer.accept(evenSink);});});
       outputQueue.clear();
    }