unistack-org/micro
4
0
Fork 2
Code Issues 18 Pull Requests Actions Packages Projects Releases 331 Wiki Activity

specify the Accept header along with Content-Type

Browse Source
This commit is contained in:
Asim
2016-08-25 13:34:47 +01:00
parent 71d64f911f
commit b8241f3026
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
client/rpc_client.go
View File

@@ -67,6 +67,8 @@ func (r *rpcClient) call(ctx context.Context, address string, req Request, resp
msg.Header["Timeout"] = fmt.Sprintf("%d", opts.RequestTimeout) msg.Header["Timeout"] = fmt.Sprintf("%d", opts.RequestTimeout)
// set the content type for the request // set the content type for the request
msg.Header["Content-Type"] = req.ContentType() msg.Header["Content-Type"] = req.ContentType()
// set the accept header
msg.Header["Accept"] = req.ContentType()
cf, err := r.newCodec(req.ContentType()) cf, err := r.newCodec(req.ContentType())
if err != nil { if err != nil {
@@ -142,6 +144,8 @@ func (r *rpcClient) stream(ctx context.Context, address string, req Request, opt
msg.Header["Timeout"] = fmt.Sprintf("%d", opts.RequestTimeout) msg.Header["Timeout"] = fmt.Sprintf("%d", opts.RequestTimeout)
// set the content type for the request // set the content type for the request
msg.Header["Content-Type"] = req.ContentType() msg.Header["Content-Type"] = req.ContentType()
// set the accept header
msg.Header["Accept"] = req.ContentType()
cf, err := r.newCodec(req.ContentType()) cf, err := r.newCodec(req.ContentType())
if err != nil { if err != nil {