| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerStreamTest.java | 112 SendResponseHeadersCommand sendHeaders = sendHeadersCap.getValue(); in writeMessageShouldSendResponse() local
113 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in writeMessageShouldSendResponse()
114 assertThat(ImmutableListMultimap.copyOf(sendHeaders.headers())) in writeMessageShouldSendResponse()
116 assertThat(sendHeaders.endOfStream()).isFalse(); in writeMessageShouldSendResponse()
138 SendResponseHeadersCommand sendHeaders = sendHeadersCap.getValue(); in writeHeadersShouldSendHeaders() local
139 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in writeHeadersShouldSendHeaders()
140 assertThat(ImmutableListMultimap.copyOf(sendHeaders.headers())) in writeHeadersShouldSendHeaders()
142 assertThat(sendHeaders.endOfStream()).isFalse(); in writeHeadersShouldSendHeaders()
158 SendResponseHeadersCommand sendHeaders = sendHeadersCap.getValue(); in closeBeforeClientHalfCloseShouldSucceed() local
159 assertThat(sendHeaders.stream()).isSameAs(stream.transportState()); in closeBeforeClientHalfCloseShouldSucceed()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerCallImplTest.java | 120 call.sendHeaders(new Metadata()); in callTracer0()
147 call.sendHeaders(headers); in sendHeader_firstCall()
154 call.sendHeaders(new Metadata()); in sendHeader_failsOnSecondCall()
158 call.sendHeaders(new Metadata()); in sendHeader_failsOnSecondCall()
168 call.sendHeaders(new Metadata()); in sendHeader_failsOnClosed()
173 call.sendHeaders(new Metadata()); in sendMessage()
182 call.sendHeaders(new Metadata()); in sendMessage_failsOnClosed()
201 call.sendHeaders(new Metadata()); in sendMessage_closesOnFailure()
229 serverCall.sendHeaders(new Metadata()); in sendMessage_serverSendsOne_closeOnSecondCall()
263 serverCall.sendHeaders(new Metadata()); in sendMessage_serverSendsOne_closeOnSecondCall_appRunToCompletion()
|
| D | CensusModulesTest.java | 224 call.sendHeaders(new Metadata()); in testClientInterceptors()
|
| D | ServerImplTest.java | 526 call.sendHeaders(responseHeaders); in basicExchangeHelper()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingServerCall.java | 37 public void sendHeaders(Metadata headers) { in sendHeaders() method in PartialForwardingServerCall
38 delegate().sendHeaders(headers); in sendHeaders()
|
| D | ServerCall.java | 119 public abstract void sendHeaders(Metadata headers); in sendHeaders() method in ServerCall
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
| D | HeaderServerInterceptor.java | 47 public void sendHeaders(Metadata responseHeaders) { in interceptCall()
49 super.sendHeaders(responseHeaders); in interceptCall()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 517 public void sendHeaders(Metadata responseHeaders) {
519 super.sendHeaders(responseHeaders);
545 public void sendHeaders(Metadata responseHeaders) {
547 super.sendHeaders(responseHeaders);
572 public void sendHeaders(Metadata responseHeaders) {
573 super.sendHeaders(responseHeaders);
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 153 public void sendHeaders(final Metadata headers) {
157 SerializingServerCall.super.sendHeaders(headers);
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/ |
| D | NoopServerCall.java | 43 public void sendHeaders(Metadata headers) {} in sendHeaders() method in NoopServerCall
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 270 call.sendHeaders(new Metadata()); in setup()
301 call.sendHeaders(new Metadata()); in setup()
334 call.sendHeaders(new Metadata()); in setup()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadServer.java | 202 call.sendHeaders(new Metadata()); in startCall()
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptorTest.java | 93 public void sendHeaders(Metadata headers) {
97 super.sendHeaders(headers);
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerCallImpl.java | 87 public void sendHeaders(Metadata headers) { in sendHeaders() method in ServerCallImpl
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 338 call.sendHeaders(new Metadata()); in onNext()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | BinlogHelper.java | 436 public void sendHeaders(Metadata headers) {
444 super.sendHeaders(headers);
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | CascadingTest.java | 287 call.sendHeaders(new Metadata()); in startCallTreeServer()
|
| /external/grpc-grpc/src/objective-c/GRPCClient/ |
| D | GRPCCall.m | 320 - (void)sendHeaders:(NSDictionary *)headers {
467 [self sendHeaders:_requestHeaders];
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ServerCallsTest.java | 482 public void sendHeaders(Metadata headers) { in sendHeaders() method in ServerCallsTest.ServerCallRecorder
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinlogHelperTest.java | 1106 public void sendHeaders(Metadata headers) { in serverInterceptor()
1158 interceptedCall.get().sendHeaders(serverInital); in serverInterceptor()
|