Function psubscribeToPublishedEvent

packages/redis/publisher.ts:72–85

(
  pattern: string,
  callback: (key: string) => void,
)

}

export function psubscribeToPublishedEvent(
  pattern: string,
  callback: (key: string) => void,
) {
  getRedisSub().psubscribe(pattern);
  const pmessage = (_: unknown, pattern: string, key: string) => callback(key);

  getRedisSub().on('pmessage', pmessage);

  return () => {
    getRedisSub().punsubscribe(pattern);
    getRedisSub().off('pmessage', pmessage);
  };
}