| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ClientInterceptors.java | 112 public void start(final Listener<RespT> responseListener, Metadata headers) { in wrapClientInterceptor()
118 responseListener.onMessage(message); in wrapClientInterceptor()
123 return responseListener; in wrapClientInterceptor()
167 public void start(Listener<Object> responseListener, Metadata headers) {}
215 protected abstract void checkedStart(Listener<RespT> responseListener, Metadata headers)
229 public final void start(Listener<RespT> responseListener, Metadata headers) {
231 checkedStart(responseListener, headers);
239 responseListener.onClose(Status.fromThrowable(e), new Metadata());
|
| D | ForwardingClientCall.java | 31 public void start(Listener<RespT> responseListener, Metadata headers) { in start() argument
32 delegate().start(responseListener, headers); in start()
|
| D | ClientCall.java | 173 public abstract void start(Listener<RespT> responseListener, Metadata headers); in start() argument
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | MetadataUtils.java | 86 public void start(Listener<RespT> responseListener, Metadata headers) { in start() argument
88 super.start(responseListener, headers); in start()
150 public void start(ClientCall.Listener<RespT> responseListener, Metadata headers) { in start() argument
153 super.start(new MetadataCapturingClientCallListener(responseListener), headers); in start()
159 MetadataCapturingClientCallListener(ClientCall.Listener<RespT> responseListener) { in MetadataCapturingClientCallListener() argument
160 super(responseListener); in MetadataCapturingClientCallListener()
|
| D | ClientCalls.java | 278 ClientCall.Listener<RespT> responseListener, in asyncUnaryRequestCall() argument
280 startCall(call, responseListener, streamingResponse); in asyncUnaryRequestCall()
306 ClientCall.Listener<RespT> responseListener, in startCall() argument
308 call.start(responseListener, new Metadata()); in startCall()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 141 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in unaryFutureCallSuccess()
142 listener.set(responseListener); in unaryFutureCallSuccess()
171 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in unaryFutureCallFailed()
172 listener.set(responseListener); in unaryFutureCallFailed()
198 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in unaryFutureCallCancelled()
199 listener.set(responseListener); in unaryFutureCallCancelled()
250 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
251 listener.set(responseListener); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
311 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in callStreamObserverPropagatesFlowControlRequestsToCall()
312 listener.set(responseListener); in callStreamObserverPropagatesFlowControlRequestsToCall()
[all …]
|
| /external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/ |
| D | ClientAuthInterceptorTest.java | 119 assertEquals(listener, call.responseListener); in testCopyCredentialToHeaders()
140 assertNull(call.responseListener); in testCredentialsThrows()
160 assertEquals(listener, call.responseListener); in testWithOAuth2Credential()
185 private ClientCall.Listener<Integer> responseListener; field in ClientAuthInterceptorTest.ClientCallRecorder
194 public void start(ClientCall.Listener<Integer> responseListener, Metadata headers) { in start() argument
195 this.responseListener = responseListener; in start()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/ |
| D | HeaderServerInterceptorTest.java | 99 public void start(Listener<RespT> responseListener, Metadata headers) { in serverHeaderDeliveredToClient()
100 spyListener = responseListener = in serverHeaderDeliveredToClient()
101 mock(ClientCall.Listener.class, delegatesTo(responseListener)); in serverHeaderDeliveredToClient()
102 super.start(responseListener, headers); in serverHeaderDeliveredToClient()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
| D | HeaderClientInterceptor.java | 47 public void start(Listener<RespT> responseListener, Metadata headers) { in interceptCall()
50 super.start(new SimpleForwardingClientCallListener<RespT>(responseListener) { in interceptCall()
|
| /external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/ |
| D | ClientAuthInterceptor.java | 67 protected void checkedStart(Listener<RespT> responseListener, Metadata headers) in interceptCall()
87 delegate().start(responseListener, headers); in interceptCall()
|
| /external/grpc-grpc-java/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/ |
| D | TesterActivity.java | 160 public void checkedStart(Listener<RespT> responseListener, Metadata headers) { in interceptCall()
161 delegate().start(responseListener, headers); in interceptCall()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ClientInterceptorsTest.java | 249 public void start(ClientCall.Listener<RespT> responseListener, Metadata headers) { in addOutboundHeaders()
251 super.start(responseListener, headers); in addOutboundHeaders()
280 public void start(ClientCall.Listener<RespT> responseListener, Metadata headers) { in examineInboundHeaders()
281 super.start(new SimpleForwardingClientCallListener<RespT>(responseListener) { in examineInboundHeaders()
346 protected void checkedStart(ClientCall.Listener<RespT> responseListener, Metadata headers) in exceptionInStart()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinaryLogProviderTest.java | 131 public void start(Listener<ResponseT> responseListener, Metadata headers) { in wrapChannel_handler()
132 listener.set(responseListener); in wrapChannel_handler()
314 public void start(Listener<RespT> responseListener, Metadata headers) { in interceptCall()
316 new SimpleForwardingClientCallListener<RespT>(responseListener) { in interceptCall()
|
| D | BinlogHelperTest.java | 1093 public void start(Listener<ResponseT> responseListener, Metadata headers) { in clientInterceptor()
1094 interceptedListener.set(responseListener); in clientInterceptor()
1258 public void start(Listener<ResponseT> responseListener, Metadata headers) { in clientInterceptor_trailersOnlyResponseLogsPeerAddress()
1259 interceptedListener.set(responseListener); in clientInterceptor_trailersOnlyResponseLogsPeerAddress()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | TransportCompressionTest.java | 147 final ClientCall.Listener<RespT> responseListener, Metadata headers) {
152 return responseListener;
|
| D | CompressionTest.java | 293 public void start(io.grpc.ClientCall.Listener<RespT> responseListener, Metadata headers) { in start() argument
294 super.start(new ClientHeadersCapture<RespT>(responseListener), headers); in start()
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptor.java | 181 public void start(Listener<RespT> responseListener, Metadata headers) {
184 responseListener) {
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | CensusTracingModule.java | 391 public void start(Listener<RespT> responseListener, Metadata headers) { in interceptCall()
393 new SimpleForwardingClientCallListener<RespT>(responseListener) { in interceptCall()
|
| D | CensusStatsModule.java | 672 public void start(Listener<RespT> responseListener, Metadata headers) { in interceptCall()
674 new SimpleForwardingClientCallListener<RespT>(responseListener) { in interceptCall()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | BinlogHelper.java | 416 public void start(final Listener<RespT> responseListener, Metadata headers) { in getClientInterceptor()
429 new SimpleForwardingClientCallListener<RespT>(responseListener) { in getClientInterceptor()
|