(value)
| 248 | return { |
| 249 | observable, |
| 250 | next(value) { |
| 251 | if (completed || errored) { |
| 252 | return; |
| 253 | } |
| 254 | |
| 255 | for (const { observer, subscription } of observers) { |
| 256 | if (!subscription.closed) { |
| 257 | callObserver(() => observer.next?.(value)); |
| 258 | } |
| 259 | } |
| 260 | }, |
| 261 | error(error) { |
| 262 | if (completed || errored) { |
| 263 | return; |
nothing calls this directly
no test coverage detected