type google.golang.org/grpc.Decompressor
13 uses
google.golang.org/grpc (current package)
dialoptions.go#L77: dc Decompressor
dialoptions.go#L310: func WithDecompressor(dc Decompressor) DialOption {
rpc_util.go#L112: type Decompressor interface {
rpc_util.go#L126: func NewGZIPDecompressor() Decompressor {
rpc_util.go#L944: func recvAndDecompress(p *parser, s recvCompressor, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor, isServer bool) (out mem.BufferSlice, err error) {
rpc_util.go#L985: func decompress(compressor encoding.Compressor, d mem.BufferSlice, dc Decompressor, maxReceiveMessageSize int, pool mem.BufferPool) (mem.BufferSlice, error) {
rpc_util.go#L1053: func recv(p *parser, c baseCodec, s recvCompressor, dc Decompressor, m any, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor, isServer bool) error {
server.go#L160: dc Decompressor
server.go#L434: func RPCDecompressor(dc Decompressor) ServerOption {
server.go#L1356: var dc Decompressor
stream.go#L645: decompressorV0 Decompressor
stream.go#L1406: decompressorV0 Decompressor
stream.go#L1641: decompressorV0 Decompressor