|
@@ -487,6 +487,7 @@ func (c *Client) write(ctx context.Context, msg interface{}) error {
|
|
|
}
|
|
}
|
|
|
c.writeConn.SetWriteDeadline(deadline)
|
|
c.writeConn.SetWriteDeadline(deadline)
|
|
|
err := json.NewEncoder(c.writeConn).Encode(msg)
|
|
err := json.NewEncoder(c.writeConn).Encode(msg)
|
|
|
|
|
+ c.writeConn.SetWriteDeadline(time.Time{})
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
c.writeConn = nil
|
|
c.writeConn = nil
|
|
|
}
|
|
}
|