Function subscribeToPublishedEvent

packages/redis/publisher.ts:45–70

(
  channel: Channel,
  type: keyof IPublishChannels[Channel],
  callback: (event: IPublishChannels[Channel][typeof type]) => void,
)

}

export function subscribeToPublishedEvent<
  Channel extends keyof IPublishChannels,
>(
  channel: Channel,
  type: keyof IPublishChannels[Channel],
  callback: (event: IPublishChannels[Channel][typeof type]) => void,
) {
  const subscribeChannel = getSubscribeChannel(channel, type);
  getRedisSub().subscribe(subscribeChannel);

  const message = (messageChannel: string, message: string) => {
    if (subscribeChannel === messageChannel) {
      const event = parsePublishedEvent(channel, type, message);
      if (event) {
        callback(event);
      }
    }
  };

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

  return () => {
    getRedisSub().unsubscribe(subscribeChannel);
    getRedisSub().off('message', message);
  };
}

export function psubscribeToPublishedEvent(
  pattern: string,