(streamId: string, controller: AbortController)
| 61 | } |
| 62 | |
| 63 | export function registerActiveStream(streamId: string, controller: AbortController): void { |
| 64 | activeStreams.set(streamId, controller) |
| 65 | } |
| 66 | |
| 67 | export function unregisterActiveStream(streamId: string): void { |
| 68 | activeStreams.delete(streamId) |