Don't attempt to reconenct if we're actually closign down

client/client.go

@@ -246,7 +246,9 @@ func (s *Subscriber) readLoop(ctx context.Context) {
 	for {
 		err := wsjson.Read(ctx, s.conn, &msg)
 		if err != nil {
-			s.closeAndReconnect()
+			if websocket.CloseStatus(err) != websocket.StatusNormalClosure {
+				s.closeAndReconnect()
+			}
 			return
 		}
 
@@ -287,7 +289,10 @@ func (s *Subscriber) heartbeat(ctx context.Context, d time.Duration) {
 		// c.Ping returns on receiving a pong
 		err := s.conn.Ping(ctx)
 		if err != nil {
-			s.closeAndReconnect()
+			if websocket.CloseStatus(err) != websocket.StatusNormalClosure {
+				s.closeAndReconnect()
+			}
+			return
 		}
 		t.Reset(time.Minute)
 	}