(sessionId: string, turnId: string)
| 695 | } |
| 696 | |
| 697 | function trackPendingInvocation(sessionId: string, turnId: string): () => void { |
| 698 | const turns = pendingInvocationTurns.get(sessionId) ?? new Set<string>(); |
| 699 | turns.add(turnId); |
| 700 | pendingInvocationTurns.set(sessionId, turns); |
| 701 | return () => { |
| 702 | turns.delete(turnId); |
| 703 | if (turns.size === 0) pendingInvocationTurns.delete(sessionId); |
| 704 | }; |
| 705 | } |
| 706 | |
| 707 | function invalidateObservation(sessionId: string): void { |
| 708 | const record = observations.get(sessionId); |
no test coverage detected