| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedStreamTest.java | 98 stream.setMessageCompression(true); in setStream_sendsAllMessages()
101 stream.setMessageCompression(false); in setStream_sendsAllMessages()
109 verify(realStream).setMessageCompression(true); in setStream_sendsAllMessages()
110 verify(realStream).setMessageCompression(false); in setStream_sendsAllMessages()
159 stream.setMessageCompression(false); in setStream_setMessageCompression()
161 verify(realStream).setMessageCompression(false); in setStream_setMessageCompression()
163 stream.setMessageCompression(true); in setStream_setMessageCompression()
164 verify(realStream).setMessageCompression(true); in setStream_setMessageCompression()
|
| D | ForwardingClientStreamTest.java | 87 forward.setMessageCompression(true); in setMessageCompressionTest()
88 verify(mock).setMessageCompression(true); in setMessageCompressionTest()
|
| D | MessageFramerTest.java | 279 .setMessageCompression(true);
305 .setMessageCompression(false);
349 framer.setMessageCompression(true);
|
| D | ServerCallImplTest.java | 338 public void setMessageCompression() { in setMessageCompression() method in ServerCallImplTest
339 call.setMessageCompression(true); in setMessageCompression()
341 verify(stream).setMessageCompression(true); in setMessageCompression()
|
| D | RetriableStreamTest.java | 207 retriableStream.setMessageCompression(true); in retry_everythingDrained()
209 retriableStream.setMessageCompression(false); in retry_everythingDrained()
225 inOrder.verify(mockStream1).setMessageCompression(true); in retry_everythingDrained()
227 inOrder.verify(mockStream1).setMessageCompression(false); in retry_everythingDrained()
270 inOrder.verify(mockStream2).setMessageCompression(true); in retry_everythingDrained()
272 inOrder.verify(mockStream2).setMessageCompression(false); in retry_everythingDrained()
317 inOrder.verify(mockStream3).setMessageCompression(true); in retry_everythingDrained()
319 inOrder.verify(mockStream3).setMessageCompression(false); in retry_everythingDrained()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingClientCall.java | 48 public void setMessageCompression(boolean enabled) { in setMessageCompression() method in PartialForwardingClientCall
49 delegate().setMessageCompression(enabled); in setMessageCompression()
|
| D | PartialForwardingServerCall.java | 58 public void setMessageCompression(boolean enabled) { in setMessageCompression() method in PartialForwardingServerCall
59 delegate().setMessageCompression(enabled); in setMessageCompression()
|
| D | ClientCall.java | 256 public void setMessageCompression(boolean enabled) { in setMessageCompression() method in ClientCall
|
| D | ServerCall.java | 173 public void setMessageCompression(boolean enabled) { in setMessageCompression() method in ServerCall
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingClientStream.java | 56 public void setMessageCompression(boolean enable) { in setMessageCompression() method in ForwardingClientStream
57 delegate().setMessageCompression(enable); in setMessageCompression()
|
| D | AbstractStream.java | 44 public final void setMessageCompression(boolean enable) { in setMessageCompression() method in AbstractStream
45 framer().setMessageCompression(enable); in setMessageCompression()
|
| D | DelayedStream.java | 348 public void setMessageCompression(final boolean enable) { in setMessageCompression() method in DelayedStream
350 realStream.setMessageCompression(enable); in setMessageCompression()
355 realStream.setMessageCompression(enable); in setMessageCompression()
|
| D | Stream.java | 82 void setMessageCompression(boolean enable); in setMessageCompression() method
|
| D | Framer.java | 44 Framer setMessageCompression(boolean enable); in setMessageCompression() method
|
| D | NoopClientStream.java | 65 public void setMessageCompression(boolean enable) { in setMessageCompression() method in NoopClientStream
|
| D | ServerCallImpl.java | 152 public void setMessageCompression(boolean enable) { in setMessageCompression() method in ServerCallImpl
153 stream.setMessageCompression(enable); in setMessageCompression()
|
| D | ClientCallImpl.java | 440 public void setMessageCompression(boolean enabled) { in setMessageCompression() method in ClientCallImpl
442 stream.setMessageCompression(enabled); in setMessageCompression()
|
| D | MessageFramer.java | 109 public MessageFramer setMessageCompression(boolean enable) { in setMessageCompression() method in MessageFramer
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | CallStreamObserver.java | 111 public abstract void setMessageCompression(boolean enable); in setMessageCompression() method in CallStreamObserver
|
| D | ServerCalls.java | 323 public void setMessageCompression(boolean enable) { in setMessageCompression() method in ServerCalls.ServerCallStreamObserverImpl
324 call.setMessageCompression(enable); in setMessageCompression()
|
| D | ClientCalls.java | 375 public void setMessageCompression(boolean enable) { in setMessageCompression() method in ClientCalls.CallToStreamObserverAdapter
376 call.setMessageCompression(enable); in setMessageCompression()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 213 public void setMessageCompression(final boolean enabled) {
217 SerializingServerCall.super.setMessageCompression(enabled);
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | TransportCompressionTest.java | 98 call.setMessageCompression(true); in getServerBuilder()
165 setMessageCompression(true);
|
| D | CompressionTest.java | 266 call.setMessageCompression(enableServerMessageCompression); in interceptCall()
295 setMessageCompression(enableClientMessageCompression); in start()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 474 public void setMessageCompression(boolean enable) {
641 public void setMessageCompression(boolean enable) {}
|