(targetInstanceUuid: string, socket: Socket)
| 233 | } |
| 234 | |
| 235 | stopForward(targetInstanceUuid: string, socket: Socket) { |
| 236 | try { |
| 237 | const instance = this.getInstance(targetInstanceUuid); |
| 238 | if (!instance) throw new Error($t("TXT_CODE_3bfb9e04")); |
| 239 | instance.watchers.delete(socket.id); |
| 240 | this.instanceStream.cannelForward(socket, targetInstanceUuid); |
| 241 | } catch (err) {} |
| 242 | } |
| 243 | |
| 244 | forEachForward(instanceUuid: string, callback: (socket: Socket) => void) { |
| 245 | this.instanceStream.forwardViaCallback(instanceUuid, (_socket: Socket) => { |
no test coverage detected