Options
All
  • Public
  • Public/Protected
  • All
Menu

Class AsyncEmitter<T>

Type parameters

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Properties

Protected _callbacks

_callbacks: undefined | CallbackList

Protected deliveryQueue

deliveryQueue: undefined | Promise<void>

Accessors

event

Methods

Protected checkMaxListeners

  • checkMaxListeners(maxListeners: number): undefined | (() => void)

Protected deliver

  • deliver(listeners: Callback[], event: Pick<T, Exclude<keyof T, "waitUntil">>, token: CancellationToken, promiseJoin?: (p: Promise<any>, listener: Function) => Promise<any>): Promise<void>

  • Parameters

    • listeners: Callback[]
    • event: Pick<T, Exclude<keyof T, "waitUntil">>
    • token: CancellationToken
    • Optional promiseJoin: (p: Promise<any>, listener: Function) => Promise<any>
        • (p: Promise<any>, listener: Function): Promise<any>

        • Parameters

          • p: Promise<any>
          • listener: Function

          Returns Promise<any>

    Returns Promise<void>

dispose

  • dispose(): void

fire

  • fire(event: Pick<T, Exclude<keyof T, "waitUntil">>, token?: CancellationToken, promiseJoin?: (p: Promise<any>, listener: Function) => Promise<any>): Promise<void>

  • Fire listeners async one after another.

    Parameters

    • event: Pick<T, Exclude<keyof T, "waitUntil">>
    • token: CancellationToken = ...
    • Optional promiseJoin: (p: Promise<any>, listener: Function) => Promise<any>
        • (p: Promise<any>, listener: Function): Promise<any>

        • Parameters

          • p: Promise<any>
          • listener: Function

          Returns Promise<any>

    Returns Promise<void>

Protected popLeakingStack

  • popLeakingStack(stack: string): void

Protected pushLeakingStack

  • pushLeakingStack(): () => void

sequence

  • sequence(processor: (listener: (e: T) => any) => MaybePromise<boolean>): Promise<void>