(error)
| 259 | } |
| 260 | }, |
| 261 | error(error) { |
| 262 | if (completed || errored) { |
| 263 | return; |
| 264 | } |
| 265 | |
| 266 | errored = true; |
| 267 | thrownError = error; |
| 268 | for (const { observer, subscription } of observers) { |
| 269 | subscription.closed = true; |
| 270 | callObserver(() => observer.error?.(error)); |
| 271 | } |
| 272 | observers.clear(); |
| 273 | }, |
| 274 | complete() { |
| 275 | if (completed || errored) { |
| 276 | return; |
nothing calls this directly
no test coverage detected