@Test(timeout = 60000) public void testOnWriteFailed() throws Exception { rule.publisher.onWriteFailed(1, TimeUnit.MILLISECONDS, new NullPointerException()); rule.listener.getTcpDelegate().getConnDelegate().assertMethodsCalled(Event.WriteFailed); }
@Override public void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable) { tcpDelegate.onWriteFailed(duration, timeUnit, throwable); }
HttpServerEventPublisher extends HttpServerEventsListener implements EventSource<HttpServerEventsListener>, EventPublisher { @Override public void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable) { tcpDelegate.onWriteFailed(duration, timeUnit, throwable); } }
HttpServerEventPublisher extends HttpServerEventsListener implements EventSource<HttpServerEventsListener>, EventPublisher { @Override public void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable) { tcpDelegate.onWriteFailed(duration, timeUnit, throwable); } HttpServerEventPublisher(TcpServerEventPublisher tcpDelegate);  HttpServerEventPublisher(TcpServerEventPublisher tcpDelegate, ListenersHolder<HttpServerEventsListener> l); }
HttpServerEventPublisher extends HttpServerEventsListener implements EventSource<HttpServerEventsListener>, EventPublisher { @Override public void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable) { tcpDelegate.onWriteFailed(duration, timeUnit, throwable); } HttpServerEventPublisher(TcpServerEventPublisher tcpDelegate);  HttpServerEventPublisher(TcpServerEventPublisher tcpDelegate, ListenersHolder<HttpServerEventsListener> l); @Override void onNewRequestReceived(); @Override void onRequestHandlingStart(final long duration, final TimeUnit timeUnit); @Override void onRequestHandlingSuccess(final long duration, final TimeUnit timeUnit); @Override void onRequestHandlingFailed(final long duration, final TimeUnit timeUnit, final Throwable throwable); @Override void onRequestHeadersReceived(); @Override void onRequestContentReceived(); @Override void onRequestReceiveComplete(final long duration, final TimeUnit timeUnit); @Override void onResponseWriteStart(); @Override void onResponseWriteSuccess(final long duration, final TimeUnit timeUnit, final int responseCode); @Override void onResponseWriteFailed(final long duration, final TimeUnit timeUnit, final Throwable throwable); @Override void onConnectionCloseFailed(long duration, TimeUnit timeUnit,
                                        Throwable throwable); @Override void onConnectionCloseSuccess(long duration, TimeUnit timeUnit); @Override void onConnectionCloseStart(); @Override void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable); @Override void onWriteSuccess(long duration, TimeUnit timeUnit); @Override void onWriteStart(); @Override void onFlushComplete(long duration, TimeUnit timeUnit); @Override void onFlushStart(); @Override void onByteRead(long bytesRead); @Override void onByteWritten(long bytesWritten); @Override void onConnectionHandlingFailed(long duration, TimeUnit timeUnit,
                                           Throwable throwable); @Override void onConnectionHandlingSuccess(long duration, TimeUnit timeUnit); @Override void onConnectionHandlingStart(long duration, TimeUnit timeUnit); @Override void onCustomEvent(Object event); @Override void onCustomEvent(Object event, long duration, TimeUnit timeUnit); @Override void onCustomEvent(Object event, long duration, TimeUnit timeUnit, Throwable throwable); @Override void onCustomEvent(Object event, Throwable throwable); @Override void onNewClientConnected(); @Override boolean publishingEnabled(); @Override Subscription subscribe(HttpServerEventsListener listener); HttpServerEventPublisher copy(TcpServerEventPublisher newTcpDelegate); }
HttpServerEventPublisher extends HttpServerEventsListener implements EventSource<HttpServerEventsListener>, EventPublisher { @Override public void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable) { tcpDelegate.onWriteFailed(duration, timeUnit, throwable); } HttpServerEventPublisher(TcpServerEventPublisher tcpDelegate);  HttpServerEventPublisher(TcpServerEventPublisher tcpDelegate, ListenersHolder<HttpServerEventsListener> l); @Override void onNewRequestReceived(); @Override void onRequestHandlingStart(final long duration, final TimeUnit timeUnit); @Override void onRequestHandlingSuccess(final long duration, final TimeUnit timeUnit); @Override void onRequestHandlingFailed(final long duration, final TimeUnit timeUnit, final Throwable throwable); @Override void onRequestHeadersReceived(); @Override void onRequestContentReceived(); @Override void onRequestReceiveComplete(final long duration, final TimeUnit timeUnit); @Override void onResponseWriteStart(); @Override void onResponseWriteSuccess(final long duration, final TimeUnit timeUnit, final int responseCode); @Override void onResponseWriteFailed(final long duration, final TimeUnit timeUnit, final Throwable throwable); @Override void onConnectionCloseFailed(long duration, TimeUnit timeUnit,
                                        Throwable throwable); @Override void onConnectionCloseSuccess(long duration, TimeUnit timeUnit); @Override void onConnectionCloseStart(); @Override void onWriteFailed(long duration, TimeUnit timeUnit, Throwable throwable); @Override void onWriteSuccess(long duration, TimeUnit timeUnit); @Override void onWriteStart(); @Override void onFlushComplete(long duration, TimeUnit timeUnit); @Override void onFlushStart(); @Override void onByteRead(long bytesRead); @Override void onByteWritten(long bytesWritten); @Override void onConnectionHandlingFailed(long duration, TimeUnit timeUnit,
                                           Throwable throwable); @Override void onConnectionHandlingSuccess(long duration, TimeUnit timeUnit); @Override void onConnectionHandlingStart(long duration, TimeUnit timeUnit); @Override void onCustomEvent(Object event); @Override void onCustomEvent(Object event, long duration, TimeUnit timeUnit); @Override void onCustomEvent(Object event, long duration, TimeUnit timeUnit, Throwable throwable); @Override void onCustomEvent(Object event, Throwable throwable); @Override void onNewClientConnected(); @Override boolean publishingEnabled(); @Override Subscription subscribe(HttpServerEventsListener listener); HttpServerEventPublisher copy(TcpServerEventPublisher newTcpDelegate);  }