Class PubSub

Private #isActive

Private #listeners

Private #subscribing

Private #emitPubSubMessage

• #emitPubSubMessage(type, message, channel, pattern?): void

• Parameters

  • type: PubSubType

  • message: Buffer

  • channel: Buffer

  • Optional pattern: Buffer

  Returns void

Private #extendChannelListeners

• #extendChannelListeners(type, channel, listeners): boolean

• Parameters

  • type: PubSubType

  • channel: string

  • listeners: ChannelListeners

  Returns boolean

Private #unsubscribeCommand

• #unsubscribeCommand(args, channelsCounter, removeListeners): {
      args: RedisCommandArgument[];
      channelsCounter: number;
      reject: undefined;
      resolve: (() => void);
  }

• Parameters

  • args: RedisCommandArgument[]

  • channelsCounter: number

  • removeListeners: (() => void)

    • • (): void

      • Returns void

  Returns {
      args: RedisCommandArgument[];
      channelsCounter: number;
      reject: undefined;
      resolve: (() => void);
  }

  • args: RedisCommandArgument[]

  • channelsCounter: number

  • reject: undefined

  • resolve: (() => void)

    • • (): void

      • Returns void

Private #updateIsActive

• #updateIsActive(): void

• Returns void

Static Private #channelsArray

• #channelsArray(channels): string[]

• Parameters

  • channels: string | string[]

  Returns string[]

Static Private #listenersSet

• #listenersSet<T>(listeners, returnBuffers?): Set<PubSubListener<true>>

• Type Parameters

  • T extends boolean

  Parameters

  • listeners: ChannelListeners

  • Optional returnBuffers: T

  Returns Set<PubSubListener<true>>