()
| 272 | observers.clear(); |
| 273 | }, |
| 274 | complete() { |
| 275 | if (completed || errored) { |
| 276 | return; |
| 277 | } |
| 278 | |
| 279 | completed = true; |
| 280 | for (const { observer, subscription } of observers) { |
| 281 | subscription.closed = true; |
| 282 | callObserver(() => observer.complete?.()); |
| 283 | } |
| 284 | observers.clear(); |
| 285 | }, |
| 286 | }; |
| 287 | } |
| 288 |
nothing calls this directly
no test coverage detected