Class PubSub<L>

_logEmitter

call

addEventListener

• addEventListener<U extends string | number>(
      event: U,
      fn: DefaultListener[U],
      opt?: EmitterSubscriberOptions,
  ): DisposerFunction

  Type Parameters

  • U extends string | number

  Parameters

  • event: U
  • fn: DefaultListener[U]
  • opt: EmitterSubscriberOptions = {}

  Returns DisposerFunction

get

• get<U extends string | number | symbol>(
      event: U,
      ...args: Parameters<L[U]>,
  ): Promise<ReturnType<L[U]> | undefined>

  Emits an event to all subscribers and executes their corresponding event handlers.

  Type Parameters

  • U extends string | number | symbol

  Parameters

  • event: U

    The event to emit.

  • ...args: Parameters<L[U]>

    The arguments to pass to the event handlers.

  Returns Promise<ReturnType<L[U]> | undefined>

  A promise that resolves to the result of the first subscriber's handler, or undefined if no subscribers are present.

getAll

• getAll<U extends string | number | symbol>(
      event: U,
      ...args: Parameters<L[U]>,
  ): Promise<ReturnType<L[U]>[] | undefined>

  Emits an event to all subscribers and executes their corresponding event handlers.

  Type Parameters

  • U extends string | number | symbol

  Parameters

  • event: U

    The event to emit.

  • ...args: Parameters<L[U]>

    The arguments to pass to the event handlers.

  Returns Promise<ReturnType<L[U]>[] | undefined>

  A promise that resolves to an array of results from all subscribers, or undefined if no subscribers are present.

hasListeners

• hasListeners(event: string | number): boolean

  Parameters

  • event: string | number

  Returns boolean

off

• off<U extends string | number>(event: U, listener: DefaultListener[U]): this

  Type Parameters

  • U extends string | number

  Parameters

  • event: U
  • listener: DefaultListener[U]

  Returns this

on

• on<U extends string | number>(
      event: U,
      fn: DefaultListener[U],
      opt?: EmitterSubscriberOptions,
  ): DisposerFunction

  Type Parameters

  • U extends string | number

  Parameters

  • event: U
  • fn: DefaultListener[U]
  • opt: EmitterSubscriberOptions = {}

  Returns DisposerFunction

onAny

• onAny(fn: EmitterHandler): void

  Parameters

  • fn: EmitterHandler

  Returns void

onCall

• onCall(handlers: Partial<LocalListener>): void

  Parameters

  • handlers: Partial<LocalListener>

  Returns void

once

• once<U extends string | number>(
      event: U,
      listener: DefaultListener[U],
  ): DisposerFunction

  Type Parameters

  • U extends string | number

  Parameters

  • event: U
  • listener: DefaultListener[U]

  Returns DisposerFunction

removeAllListeners

• removeAllListeners(): this

  Returns this

removeEventListener

• removeEventListener<U extends string | number>(
      event: U,
      listener: DefaultListener[U],
  ): this

  Type Parameters

  • U extends string | number

  Parameters

  • event: U
  • listener: DefaultListener[U]

  Returns this

waitOn

• waitOn<U extends string | number, R = Parameters<DefaultListener[U]>[0]>(
      event: U,
      timeoutMS?: number,
  ): Promise<R>

  Type Parameters

  • U extends string | number
  • R = Parameters<DefaultListener[U]>[0]

  Parameters

  • event: U
  • timeoutMS: number = 1000

  Returns Promise<R>