@Test public void testOnErrorNull() { try (JerseySseBroadcaster broadcaster = new JerseySseBroadcaster()) { thrown.expect(IllegalArgumentException.class); broadcaster.onError(null); } }
@Override public void onError(BiConsumer<SseEventSink, Throwable> onError) { if (onError == null) { throw new IllegalArgumentException(LocalizationMessages.PARAM_NULL("onError")); } onExceptionListeners.add(onError); }
JerseySseBroadcaster extends JerseyPublisher<OutboundSseEvent> implements SseBroadcaster { @Override public void onError(BiConsumer<SseEventSink, Throwable> onError) { if (onError == null) { throw new IllegalArgumentException(LocalizationMessages.PARAM_NULL("onError")); } onExceptionListeners.add(onError); } }
JerseySseBroadcaster extends JerseyPublisher<OutboundSseEvent> implements SseBroadcaster { @Override public void onError(BiConsumer<SseEventSink, Throwable> onError) { if (onError == null) { throw new IllegalArgumentException(LocalizationMessages.PARAM_NULL("onError")); } onExceptionListeners.add(onError); } JerseySseBroadcaster();   JerseySseBroadcaster(final ExecutorService executorService); }
JerseySseBroadcaster extends JerseyPublisher<OutboundSseEvent> implements SseBroadcaster { @Override public void onError(BiConsumer<SseEventSink, Throwable> onError) { if (onError == null) { throw new IllegalArgumentException(LocalizationMessages.PARAM_NULL("onError")); } onExceptionListeners.add(onError); } JerseySseBroadcaster();   JerseySseBroadcaster(final ExecutorService executorService); @Override void register(SseEventSink sseEventSink); @Override void onError(BiConsumer<SseEventSink, Throwable> onError); @Override void onClose(Consumer<SseEventSink> onClose); @Override CompletionStage<?> broadcast(final OutboundSseEvent event); }
JerseySseBroadcaster extends JerseyPublisher<OutboundSseEvent> implements SseBroadcaster { @Override public void onError(BiConsumer<SseEventSink, Throwable> onError) { if (onError == null) { throw new IllegalArgumentException(LocalizationMessages.PARAM_NULL("onError")); } onExceptionListeners.add(onError); } JerseySseBroadcaster();   JerseySseBroadcaster(final ExecutorService executorService); @Override void register(SseEventSink sseEventSink); @Override void onError(BiConsumer<SseEventSink, Throwable> onError); @Override void onClose(Consumer<SseEventSink> onClose); @Override CompletionStage<?> broadcast(final OutboundSseEvent event);  }