fix sharded test

Author: darrachequesne

lib/adapter.ts

@@ -276,7 +276,6 @@ class RedisStreamsAdapter extends ClusterAdapter {
   readonly #opts: Required<RedisStreamsAdapterOptions>;
   readonly #streamName: string;
   readonly #publicChannel: string;
-  readonly #privateChannel: string;
 
   constructor(
     nsp: any,
@@ -291,12 +290,12 @@ class RedisStreamsAdapter extends ClusterAdapter {
     this.#streamName = computeStreamName(nsp.name, opts);
 
     this.#publicChannel = `${opts.channelPrefix}#${nsp.name}#`;
-    this.#privateChannel = `${opts.channelPrefix}#${nsp.name}#${this.uid}#`;
+    const privateChannel = `${opts.channelPrefix}#${nsp.name}#${this.uid}#`;
 
     subClientPromise.then((subClient) => {
       (this.#opts.useShardedPubSub ? SSUBSCRIBE : SUBSCRIBE)(
         subClient,
-        [this.#publicChannel, this.#privateChannel],
+        [this.#publicChannel, privateChannel],
         (payload: Buffer) => {
           try {
             const message = decode(payload) as ClusterMessage;

lib/util.ts

@@ -246,9 +246,14 @@ export function SSUBSCRIBE(
   listener: (payload: Buffer) => void
 ) {
   if (isRedisV4Client(subClient)) {
-    subClient.sSubscribe(channels, listener, RETURN_BUFFERS);
+    // note: we could also have used a hash tag ({...}) to ensure the channels are mapped to the same slot
+    for (const channel of channels) {
+      subClient.sSubscribe(channel, listener, RETURN_BUFFERS);
+    }
   } else {
-    subClient.ssubscribe(channels);
+    for (const channel of channels) {
+      subClient.ssubscribe(channel);
+    }
     subClient.on("smessageBuffer", (channel: Buffer, payload: Buffer) => {
       if (channels.includes(channel.toString())) {
         listener(payload);