Releases all streams used by a specific agent.
(agentId: string)
| 146 | |
| 147 | /** Releases all streams used by a specific agent. */ |
| 148 | public releaseStreamsForAgent(agentId: string): void { |
| 149 | Logger.debug("StreamManager", `Releasing all streams for agent '${agentId}'`); |
| 150 | this.userSets.forEach((users, _type) => { |
| 151 | if (users.has(agentId)) { |
| 152 | users.delete(agentId); |
| 153 | } |
| 154 | }); |
| 155 | this.checkForTeardown(); |
| 156 | } |
| 157 | |
| 158 | // --- Subscriber Management API --- |
| 159 |
no test coverage detected