@Test
public void testOnNextExceptionHandlerAfterSubscribe() {

    DirectProcessor<String> publisher = DirectProcessor.create();
    Disposable disposable = ServerStreamingMethodHandler.internalHandleResult(publisher, responseObserver);
    publisher.onNext("a");
    publisher.onNext("b");
    assertThat(disposable.isDisposed()).isTrue();
}