@Test @DisplayName("re-throw an error passed to `onError` as `IllegalStateException`") void rethrowError() { RuntimeException exception = new RuntimeException("Test Ack publisher exception."); IllegalStateException thrown = assertThrows(IllegalStateException.class, () -> publisher.onError(exception)); assertThat(thrown.getCause()).isEqualTo(exception); }
@Override public void onError(Throwable t) { throw new IllegalStateException(t); }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onError(Throwable t) { throw new IllegalStateException(t); } }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onError(Throwable t) { throw new IllegalStateException(t); } AckRejectionPublisher(EventBus eventBus); }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onError(Throwable t) { throw new IllegalStateException(t); } AckRejectionPublisher(EventBus eventBus); @Override void onNext(Ack value); @Override void onError(Throwable t); @Override void onCompleted(); }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onError(Throwable t) { throw new IllegalStateException(t); } AckRejectionPublisher(EventBus eventBus); @Override void onNext(Ack value); @Override void onError(Throwable t); @Override void onCompleted();  }