Home
last modified time | relevance | path

Searched refs:fullStreamDecompressor (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DMessageDeframer.java93 private GzipInflatingBuffer fullStreamDecompressor; field in MessageDeframer
141 checkState(fullStreamDecompressor == null, "Already set full stream decompressor"); in setDecompressor()
146 public void setFullStreamDecompressor(GzipInflatingBuffer fullStreamDecompressor) { in setFullStreamDecompressor() argument
148 checkState(this.fullStreamDecompressor == null, "full stream decompressor already set"); in setFullStreamDecompressor()
149 this.fullStreamDecompressor = in setFullStreamDecompressor()
150 checkNotNull(fullStreamDecompressor, "Can't pass a null full stream decompressor"); in setFullStreamDecompressor()
170 if (fullStreamDecompressor != null) { in deframe()
171 fullStreamDecompressor.addGzippedBytes(data); in deframe()
214 if (fullStreamDecompressor != null) { in close()
215 hasPartialMessage = hasPartialMessage || fullStreamDecompressor.hasPartialData(); in close()
[all …]
DApplicationThreadDeframer.java67 public void setFullStreamDecompressor(GzipInflatingBuffer fullStreamDecompressor) { in setFullStreamDecompressor() argument
68 deframer.setFullStreamDecompressor(fullStreamDecompressor); in setFullStreamDecompressor()
DAbstractStream.java149 protected void setFullStreamDecompressor(GzipInflatingBuffer fullStreamDecompressor) { in setFullStreamDecompressor() argument
150 deframer.setFullStreamDecompressor(fullStreamDecompressor); in setFullStreamDecompressor()
DDeframer.java41 void setFullStreamDecompressor(GzipInflatingBuffer fullStreamDecompressor); in setFullStreamDecompressor() argument