diff --git a/api/rpc/client/init.go b/api/rpc/client/init.go index 08a9925..834f5da 100644 --- a/api/rpc/client/init.go +++ b/api/rpc/client/init.go @@ -101,7 +101,7 @@ func (c *Client) initInternal(info common.CallMethodInfo, opts ...CallOption) (* if res.stream != nil && res.err == nil { _ = res.stream.CloseSend() } - return nil, context.Canceled + return nil, context.DeadlineExceeded case res = <-newStreamCh: }