|
@@ -179,7 +179,7 @@ func (r *Client) readClientWsQuoteMessage() {
|
|
|
mt, msg, err := r.wsQuoteConn.ReadMessage()
|
|
mt, msg, err := r.wsQuoteConn.ReadMessage()
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
fmt.Printf("readClientWsQuoteMessage: %v\n", err)
|
|
fmt.Printf("readClientWsQuoteMessage: %v\n", err)
|
|
|
- break
|
|
|
|
|
|
|
+ return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
switch mt {
|
|
switch mt {
|
|
@@ -283,7 +283,7 @@ func (r *Client) readClientWsTradeMessage() {
|
|
|
mt, msg, err := r.wsTradeConn.ReadMessage()
|
|
mt, msg, err := r.wsTradeConn.ReadMessage()
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
fmt.Printf("readClientWsTradeMessage: %v\n", err)
|
|
fmt.Printf("readClientWsTradeMessage: %v\n", err)
|
|
|
- break
|
|
|
|
|
|
|
+ return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
switch mt {
|
|
switch mt {
|
