Skip to content
This repository was archived by the owner on May 28, 2018. It is now read-only.

Commit 8fa18c6

Browse files
author
Adam Lindenthal
committed
SseEventSink.send() should throw ISE after eventSink has been closed
Change-Id: I6921d6d01a90043f80120d9d1ab988b4d3a58ea1
1 parent eccbc3c commit 8fa18c6

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

media/sse/src/main/java/org/glassfish/jersey/media/sse/internal/JerseyEventSink.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ public void close() {
114114

115115
@Override
116116
public CompletionStage<?> send(OutboundSseEvent event) {
117+
checkClosed();
117118
try {
118119
this.write(event);
119120
return CompletableFuture.completedFuture(null);

media/sse/src/test/java/org/glassfish/jersey/media/sse/internal/JerseyEventSinkTest.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,4 +87,13 @@ public void onComplete() throws Exception {
8787
thrown.expect(IllegalStateException.class);
8888
eventSink.onComplete();
8989
}
90+
91+
@Test
92+
public void test() throws Exception {
93+
JerseyEventSink eventSink = new JerseyEventSink();
94+
95+
eventSink.close();
96+
thrown.expect(IllegalStateException.class);
97+
eventSink.send(null);
98+
}
9099
}

0 commit comments

Comments
 (0)