fix ci

Author: darrachequesne

lib/util.ts

@@ -226,14 +226,14 @@ const RETURN_BUFFERS = true;
 export function SUBSCRIBE(
   subClient: any,
   channels: string[],
-  listener: (payload: Uint8Array) => void
+  listener: (payload: Buffer) => void
 ) {
   if (isRedisV4Client(subClient)) {
     subClient.subscribe(channels, listener, RETURN_BUFFERS);
   } else {
     subClient.subscribe(channels);
-    subClient.on("messageBuffer", (channel: string, payload: Uint8Array) => {
-      if (channels.includes(channel)) {
+    subClient.on("messageBuffer", (channel: Buffer, payload: Buffer) => {
+      if (channels.includes(channel.toString())) {
         listener(payload);
       }
     });
@@ -243,14 +243,14 @@ export function SUBSCRIBE(
 export function SSUBSCRIBE(
   subClient: any,
   channels: string[],
-  listener: (payload: Uint8Array) => void
+  listener: (payload: Buffer) => void
 ) {
   if (isRedisV4Client(subClient)) {
     subClient.sSubscribe(channels, listener, RETURN_BUFFERS);
   } else {
     subClient.ssubscribe(channels);
-    subClient.on("smessageBuffer", (channel: string, payload: Uint8Array) => {
-      if (channels.includes(channel)) {
+    subClient.on("smessageBuffer", (channel: Buffer, payload: Buffer) => {
+      if (channels.includes(channel.toString())) {
         listener(payload);
       }
     });