diff --git a/src/controllers/api/streaming.ts b/src/controllers/api/streaming.ts
index 8b655f97..1c852592 100644
--- a/src/controllers/api/streaming.ts
+++ b/src/controllers/api/streaming.ts
@@ -61,6 +61,7 @@ const streamingController: AppController = (c) => {
 
   socket.onclose = () => {
     ws.unsubscribeAll(socket);
+    Sub.close(socket);
   };
 
   return response;