20
*/
21
export class PendingRequestRegistry<T> {
23
>
/**
24
>
* Results delivered via {@link respondOrBuffer} before any deferred was
25
>
* parked under the same key. A subsequent {@link register} consumes the
26
>
* buffered value and resolves immediately, tolerating a completion that
27
>
* races ahead of the handler that awaits it.
28
>
*/
29
>
private readonly _earlyResults = new Map<string, T>();
30
31
registerAndFire(key: string, fire: () => void): Promise<T> {