Handle subscriber removal and force websocket closure on write error

4 months ago · 5a8f0ade1a
1 changed files with 4 additions and 0 deletions
--- a/app/publisher.go
+++ b/app/publisher.go
@ -177,6 +177,10 @@ func (p *P) Deliver(ev *event.E) {
				@@ -177,6 +177,10 @@ func (p *P) Deliver(ev *event.E) {
 			if err = w.Write(
 				p.c, websocket.MessageText, res.Marshal(nil),
 			); chk.E(err) {
+				p.removeSubscriber(w)
+				if err = w.CloseNow(); chk.E(err) {
+					continue
+				}
 				continue
 			}
 			log.D.C(