(room: string)
| 217 | } |
| 218 | |
| 219 | private async unsubscribe(room: string) { |
| 220 | const controller = this.controllers.get(room) |
| 221 | if (controller) { |
| 222 | controller.abort() |
| 223 | this.controllers.delete(room) |
| 224 | logger.info(`Unsubscribed from room: ${room}`) |
| 225 | } else { |
| 226 | logger.warn(`No active subscription found for room: ${room}`) |
| 227 | } |
| 228 | } |
| 229 | } |
| 230 | |
| 231 | type Schema = z.ZodSchema | undefined |