From 5a8f0ade1ac67bde6afca0b9b2e997113619c5e8 Mon Sep 17 00:00:00 2001
From: mleku <me@mleku.dev>
Date: Wed, 3 Sep 2025 01:20:05 +0100
Subject: [PATCH] Handle subscriber removal and force websocket closure on
 write error

---
 app/publisher.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/app/publisher.go b/app/publisher.go
index 5214e9f..31677e4 100644
--- a/app/publisher.go
+++ b/app/publisher.go
@@ -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(