ensure downstream unsubscribe on upstream cleanup

Author: mfornos

src/json-rpc/upstream/server.ts

@@ -48,6 +48,14 @@ export function createUpstreamServer({
 
 	function cleanup() {
 		if (reconnectTimer) clearTimeout(reconnectTimer);
+		for (const [_, unsub] of unsubscribers) {
+			try {
+				unsub();
+			} catch {
+				//
+			}
+		}
+
 		unsubscribers.clear();
 		states.clear();
 		subscriptions.abort();

src/json-rpc/upstream/shared.ts

@@ -281,6 +281,12 @@ function _createSharedSubscription(
 				//
 			}
 
+			try {
+				onLocalUnsubscribe(localId);
+			} catch {
+				//
+			}
+
 			localSubs.delete(localId);
 
 			try {