Searched refs:requestObserverRef (Results 1 – 1 of 1) sorted by relevance
434 final AtomicReference<StreamObserver<ByteBuf>> requestObserverRef = in startStreamingCalls() local444 requestObserverRef.get().onCompleted(); in startStreamingCalls()448 requestObserverRef.get().onNext(request.slice()); in startStreamingCalls()467 requestObserverRef.set(requestObserver); in startStreamingCalls()488 final AtomicReference<StreamObserver<ByteBuf>> requestObserverRef = in startFlowControlledStreamingCalls() local496 StreamObserver<ByteBuf> obs = requestObserverRef.get(); in startFlowControlledStreamingCalls()521 requestObserverRef.set(requestObserver); in startFlowControlledStreamingCalls()