diff --git a/client/subscription/manager.go b/client/subscription/manager.go
index dc0eedb..dce70bd 100644
--- a/client/subscription/manager.go
+++ b/client/subscription/manager.go
@@ -482,7 +482,7 @@ func (m *Manager) readLoop() {
 
 		var msg Message
 		if string(data) == "PING" || string(data) == "PONG" {
-			return
+			continue
 		}
 		if err := json.Unmarshal(data, &msg); err != nil {
 			m.logger.Warn("Failed to unmarshal message", zap.Error(err))