Merge pull request #48 from shankai/master

Fix: unsubscribe single channel from (p)subscribe.
2022-03-22 10:55:55 -07:00 · 2022-03-22 10:55:55 -07:00 · 12fd027cec
parent f21745dc88 0f365a5602
commit 12fd027cec
1 changed files with 1 additions and 3 deletions
--- a/redcon.go
+++ b/redcon.go
@ -1358,14 +1358,12 @@ func (ps *PubSub) unsubscribe(conn Conn, pattern, all bool, channel string) {
 		}
 	} else {
 		// unsubscribe single channel from (p)subscribe.
-		var entry *pubSubEntry
 		for ient := range sconn.entries {
 			if ient.pattern == pattern && ient.channel == channel {
-				removeEntry(entry)
+				removeEntry(ient)
 				break
 			}
 		}
-		removeEntry(entry)
 	}
 	sconn.dconn.Flush()
 }