Function SUBSCRIBE

packages/socket.io-cluster-engine/lib/redis.ts:179–192

(
  redisClient: any,
  channels: string[],
  listener: (message: Buffer) => void,
)

const RETURN_BUFFERS = true;

function SUBSCRIBE(
  redisClient: any,
  channels: string[],
  listener: (message: Buffer) => void,
) {
  if (isRedisClient(redisClient)) {
    redisClient.subscribe(channels, listener, RETURN_BUFFERS);
  } else {
    redisClient.subscribe(channels);
    redisClient.on("messageBuffer", (_channel: Buffer, message: Buffer) =>
      listener(message),
    );
  }
}

/**
 * Whether the redis client comes from the 'redis' or the 'ioredis' package