unistack-org/micro-client-grpc
3
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases 35 Wiki Activity

add stream timeout option which defaults to 0 (#1456)

Browse Source 
* add stream timeout option which defaults to 0

* fix option
This commit is contained in:
Asim Aslam 2020-03-31 23:22:11 +01:00 committed by Vasiliy Tolstov
parent f03cb96217
commit 5a443abaf1
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
grpc.go
View File

@ -221,7 +221,9 @@ func (g *grpcClient) stream(ctx context.Context, node *registry.Node, req client
}
// set timeout in nanoseconds
header["timeout"] = fmt.Sprintf("%d", opts.RequestTimeout)
if opts.StreamTimeout > time.Duration(0) {
header["timeout"] = fmt.Sprintf("%d", opts.StreamTimeout)
}
// set the content type for the request
header["x-content-type"] = req.ContentType()