MCPcopy Create free account
hub / github.com/Roy3838/Observer / releaseStreamsForAgent

Method releaseStreamsForAgent

app/src/utils/streamManager.ts:170–178  ·  view source on GitHub ↗

Releases all streams used by a specific agent.

(agentId: string)

Source from the content-addressed store, hash-verified

168
169 /** Releases all streams used by a specific agent. */
170 public releaseStreamsForAgent(agentId: string): void {
171 Logger.debug("StreamManager", `Releasing all streams for agent '${agentId}'`);
172 this.userSets.forEach((users, _type) => {
173 if (users.has(agentId)) {
174 users.delete(agentId);
175 }
176 });
177 this.checkForTeardown();
178 }
179
180 // --- Subscriber Management API ---
181

Callers 9

handleApplyChangesFunction · 0.80
handleStopAllFunction · 0.80
handleStartTestFunction · 0.80
handleStopTestFunction · 0.80
MCPFunction · 0.80
stopMicFunction · 0.80
startMicFunction · 0.80
startAgentLoopFunction · 0.80
stopAgentLoopFunction · 0.80

Calls 3

checkForTeardownMethod · 0.95
deleteMethod · 0.80
debugMethod · 0.45

Tested by

no test coverage detected