diff --git a/gdax/listener_service.go b/gdax/listener_service.go index ac0b9ac..b9f1c5b 100644 --- a/gdax/listener_service.go +++ b/gdax/listener_service.go @@ -18,9 +18,9 @@ type ListenerService struct { closed bool shouldRestart bool - restMu sync.Mutex + restMu sync.Mutex - errorsMu sync.Mutex + errorsMu sync.Mutex sendErrors bool } diff --git a/gdax/websocket/client.go b/gdax/websocket/client.go index 04ed6ff..215d4a4 100644 --- a/gdax/websocket/client.go +++ b/gdax/websocket/client.go @@ -56,7 +56,6 @@ func (c *Client) Open() error { c.msgs <- msg } - close(c.msgs) close(c.err) }()