@@ -54,7 +54,8 @@ type RecConn struct {
|
|||||||
httpResp *http.Response
|
httpResp *http.Response
|
||||||
dialErr error
|
dialErr error
|
||||||
dialer *websocket.Dialer
|
dialer *websocket.Dialer
|
||||||
close chan (bool)
|
// if set to true, close stops dial reconnection
|
||||||
|
close chan (bool)
|
||||||
|
|
||||||
*websocket.Conn
|
*websocket.Conn
|
||||||
}
|
}
|
||||||
@@ -291,9 +292,7 @@ func (rc *RecConn) Dial(urlStr string, reqHeader http.Header) {
|
|||||||
log.Fatalf("Dial: %v", err)
|
log.Fatalf("Dial: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Close channel
|
|
||||||
rc.close = make(chan bool, 1)
|
rc.close = make(chan bool, 1)
|
||||||
|
|
||||||
// Config
|
// Config
|
||||||
rc.setURL(urlStr)
|
rc.setURL(urlStr)
|
||||||
rc.setReqHeader(reqHeader)
|
rc.setReqHeader(reqHeader)
|
||||||
|
|||||||
Reference in New Issue
Block a user