Method #emitPubSubMessage

packages/client/lib/client/pub-sub.ts:450–483

(
    type: PubSubType,
    message: Buffer,
    channel: Buffer,
    pattern?: Buffer
  )

  }

  #emitPubSubMessage(
    type: PubSubType,
    message: Buffer,
    channel: Buffer,
    pattern?: Buffer
  ): void {
    const keyString = (pattern ?? channel).toString(),
      listeners = this.listeners[type].get(keyString);

    if (!listeners) return;

    publish(CHANNELS.PUBSUB, () => ({
      direction: 'in' as const,
      clientId: this.#clientId,
      channel,
      sharded: type === PUBSUB_TYPE.SHARDED,
    }));

    for (const listener of listeners.buffers) {
      listener(message, channel);
    }

    if (!listeners.strings.size) return;

    const channelString = pattern ? channel.toString() : keyString,
      messageString = channelString === '__redis__:invalidate' ?
        // https://github.com/redis/redis/pull/7469
        // https://github.com/redis/redis/issues/7463
        (message === null ? null : (message as any as Array<Buffer>).map(x => x.toString())) as any :
        message.toString();
    for (const listener of listeners.strings) {
      listener(messageString, channelString);
    }
  }
}