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

non-blocking call chan when retries are 0

Browse Source
This commit is contained in:
Asim Aslam
2019-04-18 09:05:22 +00:00
parent 722a3682c8
commit f824ba0779
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
client/rpc_client.go
View File

@@ -382,7 +382,7 @@ func (r *rpcClient) Call(ctx context.Context, request Request, response interfac
return err return err
} }
ch := make(chan error, callOpts.Retries) ch := make(chan error, callOpts.Retries+1)
var gerr error var gerr error
for i := 0; i <= callOpts.Retries; i++ { for i := 0; i <= callOpts.Retries; i++ {
@@ -463,7 +463,7 @@ func (r *rpcClient) Stream(ctx context.Context, request Request, opts ...CallOpt
err error err error
} }
ch := make(chan response, callOpts.Retries) ch := make(chan response, callOpts.Retries+1)
var grr error var grr error
for i := 0; i <= callOpts.Retries; i++ { for i := 0; i <= callOpts.Retries; i++ {