Home
last modified time | relevance | path

Searched refs:setDecompressorRegistry (Results 1 – 13 of 13) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingClientStream.java81 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() method in ForwardingClientStream
82 delegate().setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
DClientStream.java69 void setDecompressorRegistry(DecompressorRegistry decompressorRegistry); in setDecompressorRegistry() method
DAbstractClientStream.java147 public final void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() method in AbstractClientStream
148 transportState().setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
246 private void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() method in AbstractClientStream.TransportState
DNoopClientStream.java76 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) {} in setDecompressorRegistry() method in NoopClientStream
DDelayedStream.java328 public void setDecompressorRegistry(final DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() method in DelayedStream
333 realStream.setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
DClientCallImpl.java144 ClientCallImpl<ReqT, RespT> setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() method in ClientCallImpl
271 stream.setDecompressorRegistry(decompressorRegistry); in start()
DRetriableStream.java457 public final void setDecompressorRegistry(final DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() method in RetriableStream
461 substream.stream.setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
DManagedChannelImpl.java814 .setDecompressorRegistry(decompressorRegistry) in newCall()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DForwardingClientStreamTest.java125 forward.setDecompressorRegistry(decompressor); in setDecompressorRegistryTest()
126 verify(mock).setDecompressorRegistry(same(decompressor)); in setDecompressorRegistryTest()
DClientCallImplTest.java282 .setDecompressorRegistry(decompressorRegistry); in advertisedEncodingsAreSent()
306 .setDecompressorRegistry(decompressorRegistry); in authorityPropagatedToStream()
323 .setDecompressorRegistry(decompressorRegistry); in callOptionsPropagatedToTransport()
342 .setDecompressorRegistry(decompressorRegistry); in authorityNotPropagatedToStream()
513 .setDecompressorRegistry(decompressorRegistry); in callerContextPropagatedToListener()
591 .setDecompressorRegistry(decompressorRegistry); in contextCancellationCancelsStream()
621 .setDecompressorRegistry(decompressorRegistry); in contextAlreadyCancelledNotifiesImmediately()
666 .setDecompressorRegistry(decompressorRegistry); in deadlineExceededBeforeCallStarted()
925 .setDecompressorRegistry(decompressorRegistry); in startAddsMaxSize()
DDelayedStreamTest.java96 stream.setDecompressorRegistry(DecompressorRegistry.getDefaultInstance()); in setStream_sendsAllMessages()
107 verify(realStream).setDecompressorRegistry(DecompressorRegistry.getDefaultInstance()); in setStream_sendsAllMessages()
DRetriableStreamTest.java203 retriableStream.setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()
221 inOrder.verify(mockStream1).setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()
266 inOrder.verify(mockStream2).setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()
313 inOrder.verify(mockStream3).setDecompressorRegistry(DECOMPRESSOR_REGISTRY); in retry_everythingDrained()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java674 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) {}