@Test @DisplayName("provide non-null empty observer") void createEmptyObserver() { StreamObserver<Response> emptyObserver = noOpObserver(); assertNotNull(emptyObserver); emptyObserver.onNext(Tests.nullRef()); emptyObserver.onError(Tests.nullRef()); emptyObserver.onCompleted(); }
public static <T> StreamObserver<T> noOpObserver() { return new NoOpObserver<>(); }
StreamObservers { public static <T> StreamObserver<T> noOpObserver() { return new NoOpObserver<>(); } }
StreamObservers { public static <T> StreamObserver<T> noOpObserver() { return new NoOpObserver<>(); } private  StreamObservers(); }
StreamObservers { public static <T> StreamObserver<T> noOpObserver() { return new NoOpObserver<>(); } private  StreamObservers(); static StreamObserver<T> noOpObserver(); static void ack(StreamObserver<Response> responseObserver); @Internal static StreamObserver<T> forwardErrorsOnly(StreamObserver<?> delegate); @Internal static MemoizingObserver<T> memoizingObserver(); @SuppressWarnings("ChainOfInstanceofChecks") // Only way to check an exact throwable type. static Optional<Error> fromStreamError(Throwable throwable); }
StreamObservers { public static <T> StreamObserver<T> noOpObserver() { return new NoOpObserver<>(); } private  StreamObservers(); static StreamObserver<T> noOpObserver(); static void ack(StreamObserver<Response> responseObserver); @Internal static StreamObserver<T> forwardErrorsOnly(StreamObserver<?> delegate); @Internal static MemoizingObserver<T> memoizingObserver(); @SuppressWarnings("ChainOfInstanceofChecks") // Only way to check an exact throwable type. static Optional<Error> fromStreamError(Throwable throwable);  }