From ce9d9f8b2183bc0a31bfa40e780ae07182bc7cf8 Mon Sep 17 00:00:00 2001 From: alex Date: Sun, 12 Jul 2026 14:09:36 +0200 Subject: added pubsub command registry --- pkg/commands/unsubscribe.go | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) create mode 100644 pkg/commands/unsubscribe.go (limited to 'pkg/commands/unsubscribe.go') diff --git a/pkg/commands/unsubscribe.go b/pkg/commands/unsubscribe.go new file mode 100644 index 0000000..9ca502d --- /dev/null +++ b/pkg/commands/unsubscribe.go @@ -0,0 +1,19 @@ +package commands + +import ( + "net" + "redisClone/pkg/core" + "redisClone/pkg/pubsub" +) + +func Unsubscribe(hub *pubsub.Hub, conn net.Conn, args []string) interface{}{ + channels := args[1:] + results := hub.Unsubscribe(conn, channels) + + for channel, remainingCount := range results { + resp := core.SerializeRESP([]interface{}{"unsubscribe", channel, remainingCount}) + conn.Write(resp) + } + + return nil +} \ No newline at end of file -- cgit v1.2.3