()
| 131 | } |
| 132 | |
| 133 | private cleanup(): void { |
| 134 | if (this.abortSignal && this.abortListener) { |
| 135 | this.abortSignal.removeEventListener("abort", this.abortListener); |
| 136 | } |
| 137 | |
| 138 | this.onFinish?.(); |
| 139 | } |
| 140 | |
| 141 | push(value: T): void { |
| 142 | if (this.done) { |
no test coverage detected