WIP: Use DeadlineExceeded error when creating stream failed by timeout support #335
1 changed files with 1 additions and 1 deletions
|
@ -101,7 +101,7 @@ func (c *Client) initInternal(info common.CallMethodInfo, opts ...CallOption) (*
|
||||||
if res.stream != nil && res.err == nil {
|
if res.stream != nil && res.err == nil {
|
||||||
_ = res.stream.CloseSend()
|
_ = res.stream.CloseSend()
|
||||||
}
|
}
|
||||||
return nil, context.Canceled
|
return nil, context.DeadlineExceeded
|
||||||
case res = <-newStreamCh:
|
case res = <-newStreamCh:
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue