Compare commits
1 commit
8f2c8007fd
...
2352156ee9
Author | SHA1 | Date | |
---|---|---|---|
2352156ee9 |
1 changed files with 2 additions and 1 deletions
|
@ -61,7 +61,8 @@ func (c *Client) Init(info common.CallMethodInfo, opts ...CallOption) (MessageRe
|
|||
// would propagate to all subsequent read/write operations on the opened stream,
|
||||
// which is not desired for the stream's lifecycle management.
|
||||
dialTimeoutTimer := time.NewTimer(c.dialTimeout)
|
||||
newStreamCh := make(chan interface{})
|
||||
defer dialTimeoutTimer.Stop()
|
||||
newStreamCh := make(chan struct{})
|
||||
|
||||
var stream grpc.ClientStream
|
||||
var err error
|
||||
|
|
Loading…
Add table
Reference in a new issue