@Test @DisplayName("ignore non-rejection `Ack`s") void ignoreNonRejection() { Ack ack = Acks.acknowledge(CommandId.generate()); publisher.onNext(ack); assertThat(listener.lastReceived).isNull(); }
@Override public void onNext(Ack value) { checkNotNull(value); Status status = value.getStatus(); if (status.getStatusCase() == REJECTION) { eventBus.post(status.getRejection()); } }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onNext(Ack value) { checkNotNull(value); Status status = value.getStatus(); if (status.getStatusCase() == REJECTION) { eventBus.post(status.getRejection()); } } }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onNext(Ack value) { checkNotNull(value); Status status = value.getStatus(); if (status.getStatusCase() == REJECTION) { eventBus.post(status.getRejection()); } } AckRejectionPublisher(EventBus eventBus); }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onNext(Ack value) { checkNotNull(value); Status status = value.getStatus(); if (status.getStatusCase() == REJECTION) { eventBus.post(status.getRejection()); } } AckRejectionPublisher(EventBus eventBus); @Override void onNext(Ack value); @Override void onError(Throwable t); @Override void onCompleted(); }
AckRejectionPublisher implements StreamObserver<Ack> { @Override public void onNext(Ack value) { checkNotNull(value); Status status = value.getStatus(); if (status.getStatusCase() == REJECTION) { eventBus.post(status.getRejection()); } } AckRejectionPublisher(EventBus eventBus); @Override void onNext(Ack value); @Override void onError(Throwable t); @Override void onCompleted();  }