@Test @DisplayName("create proper memoizing observer") void createMemoizingObserver() { MemoizingObserver<Object> observer = memoizingObserver(); checkFirstResponse(observer); checkOnNext(observer); checkOnError(observer); checkIsCompleted(observer); }
@Internal public static <T> MemoizingObserver<T> memoizingObserver() { return new MemoizingObserver<>(); }
StreamObservers { @Internal public static <T> MemoizingObserver<T> memoizingObserver() { return new MemoizingObserver<>(); } }
StreamObservers { @Internal public static <T> MemoizingObserver<T> memoizingObserver() { return new MemoizingObserver<>(); } private  StreamObservers(); }
StreamObservers { @Internal public static <T> MemoizingObserver<T> memoizingObserver() { return new MemoizingObserver<>(); } 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 { @Internal public static <T> MemoizingObserver<T> memoizingObserver() { return new MemoizingObserver<>(); } 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);  }