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

Method releaseStreamsForAgent

app/src/utils/streamManager.ts:148–156  ·  view source on GitHub ↗

Releases all streams used by a specific agent.

(agentId: string)

Source from the content-addressed store, hash-verified

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

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