commit 922570b675efef7ec209fddced3c3caf551b66e0
author Jan Supol <jan.supol@oracle.com> Thu Nov 21 14:35:12 2019 +0100
committer jansupol <15908245+jansupol@users.noreply.github.com> Fri Dec 06 09:17:55 2019 +0100
tree d3f5e004b1edc6b73b0886db611bbe4a9ce1116c
parent 8dcfed4836d26c57ef78be68214d186e9ca78b84

Close SseEventSink at the end of the example

Signed-off-by: Jan Supol <jan.supol@oracle.com>

examples/server-sent-events-jaxrs/src/test/java/org/glassfish/jersey/examples/sse/jaxrs/ServerSentEventsTest.java

diff --git a/examples/server-sent-events-jaxrs/src/test/java/org/glassfish/jersey/examples/sse/jaxrs/ServerSentEventsTest.java b/examples/server-sent-events-jaxrs/src/test/java/org/glassfish/jersey/examples/sse/jaxrs/ServerSentEventsTest.java
index 68fad19..7078512 100644
--- a/examples/server-sent-events-jaxrs/src/test/java/org/glassfish/jersey/examples/sse/jaxrs/ServerSentEventsTest.java
+++ b/examples/server-sent-events-jaxrs/src/test/java/org/glassfish/jersey/examples/sse/jaxrs/ServerSentEventsTest.java
@@ -86,12 +86,13 @@
         });
 
         eventSource.open();
-        target().path(App.ROOT_PATH).request().post(Entity.text("message"));
+        target().path(App.ROOT_PATH).request().post(Entity.text("message")).close();
 
         try {
             assertTrue("Waiting for message to be delivered has timed out.",
                     latch.await(5 * getAsyncTimeoutMultiplier(), TimeUnit.SECONDS));
         } finally {
+            target().path(App.ROOT_PATH).request().delete().close();
             eventSource.close();
         }
         assertThat("Unexpected SSE event data value.", message.get(), equalTo("message"));