A throwing callback (e.g. ws.send on a closed socket) would abort the for-of loop, causing remaining subscribers to miss the data chunk and skipping the ring buffer update — corrupting replay history for future reconnections. Wrapping each call in try-catch keeps all subscribers independent and ensures the buffer update always runs. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| ao | ||
| cli | ||
| core | ||
| integration-tests | ||
| plugins | ||
| web | ||