Home
last modified time | relevance | path

Searched refs:MESSAGE_ENCODING_KEY (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DCompressionTest.java21 import static io.grpc.internal.GrpcUtil.MESSAGE_ENCODING_KEY;
203 assertEquals("fzip", clientResponseHeaders.get(MESSAGE_ENCODING_KEY)); in compression()
213 assertThat(clientResponseHeaders.get(MESSAGE_ENCODING_KEY)) in compression()
233 assertEquals("fzip", serverResponseHeaders.get(MESSAGE_ENCODING_KEY)); in compression()
242 assertNull(serverResponseHeaders.get(MESSAGE_ENCODING_KEY)); in compression()
DTransportCompressionTest.java159 String encoding = headers.get(GrpcUtil.MESSAGE_ENCODING_KEY);
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerCallImpl.java24 import static io.grpc.internal.GrpcUtil.MESSAGE_ENCODING_KEY;
91 headers.discardAll(MESSAGE_ENCODING_KEY); in sendHeaders()
109 headers.put(MESSAGE_ENCODING_KEY, compressor.getMessageEncoding()); in sendHeaders()
DClientCallImpl.java28 import static io.grpc.internal.GrpcUtil.MESSAGE_ENCODING_KEY;
160 headers.discardAll(MESSAGE_ENCODING_KEY); in prepareHeaders()
162 headers.put(MESSAGE_ENCODING_KEY, compressor.getMessageEncoding()); in prepareHeaders()
DAbstractClientStream.java22 import static io.grpc.internal.GrpcUtil.MESSAGE_ENCODING_KEY;
316 String messageEncoding = headers.get(MESSAGE_ENCODING_KEY); in inboundHeadersReceived()
DServerImpl.java23 import static io.grpc.internal.GrpcUtil.MESSAGE_ENCODING_KEY;
420 if (headers.containsKey(MESSAGE_ENCODING_KEY)) { in streamCreated()
421 String encoding = headers.get(MESSAGE_ENCODING_KEY); in streamCreated()
DGrpcUtil.java89 public static final Metadata.Key<String> MESSAGE_ENCODING_KEY = field in GrpcUtil
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java262 headers.put(GrpcUtil.MESSAGE_ENCODING_KEY, new Codec.Gzip().getMessageEncoding()); in inboundHeadersReceived_disallowsContentAndMessageEncoding()
283 headers.put(GrpcUtil.MESSAGE_ENCODING_KEY, new Codec.Gzip().getMessageEncoding()); in inboundHeadersReceived_acceptsGzipMessageEncoding()
295 headers.put(GrpcUtil.MESSAGE_ENCODING_KEY, Codec.Identity.NONE.getMessageEncoding()); in inboundHeadersReceived_acceptsIdentityMessageEncoding()
307 headers.put(GrpcUtil.MESSAGE_ENCODING_KEY, "not-a-real-compression-method"); in inboundHeadersReceived_failsOnUnrecognizedMessageEncoding()
DClientCallImplTest.java363 assertNull(m.get(GrpcUtil.MESSAGE_ENCODING_KEY)); in prepareHeaders_ignoreIdentityEncoding()
484 m.put(GrpcUtil.MESSAGE_ENCODING_KEY, "gzip"); in prepareHeaders_removeReservedHeaders()
492 assertNull(m.get(GrpcUtil.MESSAGE_ENCODING_KEY)); in prepareHeaders_removeReservedHeaders()
DServerImplTest.java21 import static io.grpc.internal.GrpcUtil.MESSAGE_ENCODING_KEY;
440 requestHeaders.put(MESSAGE_ENCODING_KEY, decompressorName); in decompressorNotFound()