4
									
								
								http.go
									
									
									
									
									
								
							
							
						
						
									
										4
									
								
								http.go
									
									
									
									
									
								
							| @@ -32,10 +32,10 @@ func filterLabel(r []router.Route) []router.Route { | ||||
| */ | ||||
|  | ||||
| type httpClient struct { | ||||
| 	opts    client.Options | ||||
| 	httpcli *http.Client | ||||
| 	init    bool | ||||
| 	opts    client.Options | ||||
| 	sync.RWMutex | ||||
| 	init bool | ||||
| } | ||||
|  | ||||
| func newRequest(addr string, req client.Request, ct string, cf codec.Codec, msg interface{}, opts client.CallOptions) (*http.Request, error) { | ||||
|   | ||||
							
								
								
									
										2
									
								
								util.go
									
									
									
									
									
								
							
							
						
						
									
										2
									
								
								util.go
									
									
									
									
									
								
							| @@ -240,7 +240,7 @@ func (h *httpClient) parseRsp(ctx context.Context, hrsp *http.Response, rsp inte | ||||
| 		} | ||||
|  | ||||
| 		if cerr := cf.ReadBody(hrsp.Body, rerr); cerr != nil { | ||||
| 			err = errors.InternalServerError("go.micro.client", cerr.Error()) | ||||
| 			return errors.InternalServerError("go.micro.client", cerr.Error()) | ||||
| 		} | ||||
|  | ||||
| 		if err, ok = rerr.(error); !ok { | ||||
|   | ||||
		Reference in New Issue
	
	Block a user