Home
last modified time | relevance | path

Searched refs:setCompressor (Results 1 – 17 of 17) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingClientStream.java51 public void setCompressor(Compressor compressor) { in setCompressor() method in ForwardingClientStream
52 delegate().setCompressor(compressor); in setCompressor()
DAbstractStream.java76 public final void setCompressor(Compressor compressor) { in setCompressor() method in AbstractStream
77 framer().setCompressor(checkNotNull(compressor, "compressor")); in setCompressor()
DStream.java75 void setCompressor(Compressor compressor); in setCompressor() method
DFramer.java47 Framer setCompressor(Compressor compressor); in setCompressor() method
DNoopClientStream.java70 public void setCompressor(Compressor compressor) {} in setCompressor() method in NoopClientStream
DDelayedStream.java306 public void setCompressor(final Compressor compressor) { in setCompressor() method in DelayedStream
311 realStream.setCompressor(compressor); in setCompressor()
DServerCallImpl.java111 stream.setCompressor(compressor); in sendHeaders()
DMessageFramer.java103 public MessageFramer setCompressor(Compressor compressor) { in setCompressor() method in MessageFramer
DRetriableStream.java397 public final void setCompressor(final Compressor compressor) { in setCompressor() method in RetriableStream
401 substream.stream.setCompressor(compressor); in setCompressor()
DAbstractClientStream.java528 public Framer setCompressor(Compressor compressor) { in setCompressor() method in AbstractClientStream.GetFramer
DClientCallImpl.java267 stream.setCompressor(compressor); in start()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DForwardingClientStreamTest.java81 forward.setCompressor(compressor); in setCompressorTest()
82 verify(mock).setCompressor(same(compressor)); in setCompressorTest()
DMessageFramerTest.java253 .setCompressor(new Codec.Gzip()); in compressed()
304 .setCompressor(new Codec.Gzip())
348 framer.setCompressor(new Codec.Gzip());
DDelayedStreamTest.java95 stream.setCompressor(Codec.Identity.NONE); in setStream_sendsAllMessages()
106 verify(realStream).setCompressor(Codec.Identity.NONE); in setStream_sendsAllMessages()
DRetriableStreamTest.java202 retriableStream.setCompressor(COMPRESSOR); in retry_everythingDrained()
220 inOrder.verify(mockStream1).setCompressor(COMPRESSOR); in retry_everythingDrained()
265 inOrder.verify(mockStream2).setCompressor(COMPRESSOR); in retry_everythingDrained()
312 inOrder.verify(mockStream3).setCompressor(COMPRESSOR); in retry_everythingDrained()
DServerImplTest.java528 verify(stream).setCompressor(isA(Compressor.class)); in basicExchangeHelper()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java479 public void setCompressor(Compressor compressor) {}
668 public void setCompressor(Compressor compressor) {}