@Test public void onComplete() throws Exception { JerseyEventSink eventSink = new JerseyEventSink(null); eventSink.close(); thrown.expect(IllegalStateException.class); eventSink.onComplete(); }
public void onComplete() { checkClosed(); subscription.cancel(); close(); }
JerseyEventSink extends ChunkedOutput<OutboundSseEvent> implements SseEventSink, Flushable, Flow.Subscriber<OutboundSseEvent> { public void onComplete() { checkClosed(); subscription.cancel(); close(); } }
JerseyEventSink extends ChunkedOutput<OutboundSseEvent> implements SseEventSink, Flushable, Flow.Subscriber<OutboundSseEvent> { public void onComplete() { checkClosed(); subscription.cancel(); close(); } JerseyEventSink(Provider<AsyncContext> asyncContextProvider); }
JerseyEventSink extends ChunkedOutput<OutboundSseEvent> implements SseEventSink, Flushable, Flow.Subscriber<OutboundSseEvent> { public void onComplete() { checkClosed(); subscription.cancel(); close(); } JerseyEventSink(Provider<AsyncContext> asyncContextProvider); @Override void onSubscribe(final Flow.Subscription subscription); @Override void onNext(final OutboundSseEvent item); @Override void onError(final Throwable throwable); @Override void close(); @Override CompletionStage<?> send(OutboundSseEvent event); @Override void flush(); void onComplete(); }
JerseyEventSink extends ChunkedOutput<OutboundSseEvent> implements SseEventSink, Flushable, Flow.Subscriber<OutboundSseEvent> { public void onComplete() { checkClosed(); subscription.cancel(); close(); } JerseyEventSink(Provider<AsyncContext> asyncContextProvider); @Override void onSubscribe(final Flow.Subscription subscription); @Override void onNext(final OutboundSseEvent item); @Override void onError(final Throwable throwable); @Override void close(); @Override CompletionStage<?> send(OutboundSseEvent event); @Override void flush(); void onComplete();  }