145
/** Reject every pending deferred with `err` and clear all lists. */
146
failAll(err: Error): void {
148
>
for (const entry of list) {
149
if (!entry.deferred.isSettled) {
150
entry.deferred.error(err);
151
}
152
}
154
>
rejectAll(this._toYield);
155
>
rejectAll(this._yielded);
156
>
rejectAll(this._popped);
157
>
this._toYield = [];
158
>
this._yielded = [];
159
>
this._popped = [];
160
>
}
161
162
/** Wake any parked `next()` — call after the controller is aborted so the iterable returns `done`. */