lib: clean up persisted signals when they are settled · nodejs/node@a3c8739

}

});

});

const gcPersistentSignals = new SafeSet();

const sourceSignalsCleanupRegistry = new SafeFinalizationRegistry(({ sourceSignalRef, composedSignalRef }) => {

const composedSignal = composedSignalRef.deref();

if (composedSignal !== undefined) {

composedSignal[kSourceSignals].delete(sourceSignalRef);

if (composedSignal[kSourceSignals].size === 0) {

// This signal will no longer abort. There's no need to keep it in the gcPersistentSignals set.

gcPersistentSignals.delete(composedSignal);

}

}

});

const kAborted = Symbol('kAborted');

const kReason = Symbol('kReason');

const kCloneData = Symbol('kCloneData');

resultSignal[kSourceSignals].add(signalWeakRef);

signal[kDependantSignals].add(resultSignalWeakRef);

dependantSignalsCleanupRegistry.register(resultSignal, signalWeakRef);

sourceSignalsCleanupRegistry.register(signal, {

sourceSignalRef: signalWeakRef,

composedSignalRef: resultSignalWeakRef,

});

} else if (!signal[kSourceSignals]) {

continue;

} else {

resultSignal[kSourceSignals].add(sourceSignalWeakRef);

sourceSignal[kDependantSignals].add(resultSignalWeakRef);

dependantSignalsCleanupRegistry.register(resultSignal, sourceSignalWeakRef);

sourceSignalsCleanupRegistry.register(signal, {

sourceSignalRef: sourceSignalWeakRef,

composedSignalRef: resultSignalWeakRef,

});

}

}

}

*/

get signal() {

this.#signal ??= new AbortSignal(kDontThrowSymbol);

return this.#signal;

}