flush_v3 #188
@@ -89,8 +89,9 @@ func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.
 | 
			
		||||
 | 
			
		||||
	w := io.Writer(buf)
 | 
			
		||||
 | 
			
		||||
	if md, ok := metadata.FromOutgoingContext(ctx); gzipAccepted(md) && ok {
 | 
			
		||||
	if md, ok := metadata.FromIncomingContext(ctx); gzipAccepted(md) && ok {
 | 
			
		||||
		md.Set(contentEncodingHeader, "gzip")
 | 
			
		||||
		ctx = metadata.NewOutgoingContext(ctx, md)
 | 
			
		||||
		gz := gzipPool.Get().(*gzip.Writer)
 | 
			
		||||
		defer gzipPool.Put(gz)
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user