fix: fix NUMSUB command (#338)

denodrivers · Oct 18, 2022 · bd2fdb1 · bd2fdb1
1 parent 0d871c9
commit bd2fdb1
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 1 deletion.
diff --git a/redis.ts b/redis.ts
@@ -1180,7 +1180,7 @@ class RedisImpl implements Redis {
   pubsubNumsub(...channels: string[]) {
     return this.execArrayReply<BulkString | Integer>(
       "PUBSUB",
-      "NUMSUBS",
+      "NUMSUB",
       ...channels,
     );
   }

diff --git a/tests/commands/pubsub.ts b/tests/commands/pubsub.ts
@@ -149,4 +149,21 @@ export function pubsubTests(
       assert(sub.isClosed);
     },
   });
+
+  it("pubsubNumsub()", async () => {
+    const opts = getOpts();
+    const subClient1 = await newClient(opts);
+    await subClient1.subscribe("test1", "test2");
+
+    const subClient2 = await newClient(opts);
+    await subClient2.subscribe("test2", "test3");
+
+    const pubClient = await newClient(opts);
+    const resp = await pubClient.pubsubNumsub("test1", "test2", "test3");
+    assertEquals(resp, ["test1", 1, "test2", 2, "test3", 1]);
+
+    subClient1.close();
+    subClient2.close();
+    pubClient.close();
+  });
 }