Searched refs:CallStreamObserver (Results 1 – 5 of 5) sorted by relevance
42 final CallStreamObserver<V> target) { in copyWithFlowControl()74 CallStreamObserver<V> target) { in copyWithFlowControl()
32 public abstract class ServerCallStreamObserver<V> extends CallStreamObserver<V> {
44 public abstract class CallStreamObserver<V> implements StreamObserver<V> { class
34 public abstract class ClientCallStreamObserver<V> extends CallStreamObserver<V> {
226 CallStreamObserver<Integer> callStreamObserver = in cannotSetOnReadyAfterCallStarted()227 (CallStreamObserver<Integer>) ClientCalls.asyncClientStreamingCall(call, in cannotSetOnReadyAfterCallStarted()320 CallStreamObserver<Integer> requestObserver = in callStreamObserverPropagatesFlowControlRequestsToCall()321 (CallStreamObserver<Integer>) in callStreamObserverPropagatesFlowControlRequestsToCall()436 CallStreamObserver<Integer> integerStreamObserver = (CallStreamObserver<Integer>) in inprocessTransportInboundFlowControl()