(response *http.Response)
| 439 | } |
| 440 | |
| 441 | func (cc *grpcClientConn) validateResponse(response *http.Response) *Error { |
| 442 | if err := grpcValidateResponse( |
| 443 | response, |
| 444 | cc.responseHeader, |
| 445 | cc.compressionPools, |
| 446 | cc.unmarshaler.web, |
| 447 | cc.marshaler.codec.Name(), |
| 448 | ); err != nil { |
| 449 | return err |
| 450 | } |
| 451 | compression := getHeaderCanonical(response.Header, grpcHeaderCompression) |
| 452 | cc.unmarshaler.compressionPool = cc.compressionPools.Get(compression) |
| 453 | return nil |
| 454 | } |
| 455 | |
| 456 | type grpcHandlerConn struct { |
| 457 | spec Spec |
no test coverage detected