gopkg/recws
2
0
Fork 0
Code Activity

added lock to fix concurrency issue

Browse Source
This commit is contained in:
Lucas Löffel
2018-10-09 12:26:46 +02:00
parent 7c395c3a92
commit 3698e5f7fe
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
recws.go
+4
View File
@@ -141,9 +141,13 @@ func (rc *RecConn) ReadJSON(v interface{}) error {
// (Cookie). Use GetHTTPResponse() method for the response.Header to get // (Cookie). Use GetHTTPResponse() method for the response.Header to get
// the selected subprotocol (Sec-WebSocket-Protocol) and cookies (Set-Cookie). // the selected subprotocol (Sec-WebSocket-Protocol) and cookies (Set-Cookie).
func (rc *RecConn) Dial(urlStr string, reqHeader http.Header) { func (rc *RecConn) Dial(urlStr string, reqHeader http.Header) {
rc.mu.Lock()
defer rc.mu.Unlock()
if urlStr == "" { if urlStr == "" {
log.Fatal("Dial: Url cannot be empty") log.Fatal("Dial: Url cannot be empty")
} }
u, err := url.Parse(urlStr) u, err := url.Parse(urlStr)
if err != nil { if err != nil {