Skip to content

Commit 0a936f9

Browse files
authored
Merge pull request #37 from sqlrsync/v0.0.11
bug: crash on PONG
2 parents 00f716d + 524fead commit 0a936f9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

client/subscription/manager.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -482,7 +482,7 @@ func (m *Manager) readLoop() {
482482

483483
var msg Message
484484
if string(data) == "PING" || string(data) == "PONG" {
485-
return
485+
continue
486486
}
487487
if err := json.Unmarshal(data, &msg); err != nil {
488488
m.logger.Warn("Failed to unmarshal message", zap.Error(err))

0 commit comments

Comments
 (0)