1542
client.subscriptions.delete(classified.uri);
1543
if (sub.kind === ChannelKind.State) {
1545
>
if (record && this._hasSubscriptionInOtherConnection(record, client, sub.uri)) {
1546
return;
1547
}
1549
>
if (isAhpChatChannel(sub.uri)) {
1550
this._releaseActiveClientForSession(parseRequiredSessionUriFromChatUri(sub.uri), client.clientId, sub.uri);
1552
>
const state = this._stateManager.getSessionState(sub.uri);
1553
>
for (const chat of state?.chats ?? []) {
1554
>
this._releaseActiveClientForSession(sub.uri, client.clientId, chat.resource);
1555
>
}
1556
>
}
1557
} else if (sub.kind === ChannelKind.ResourceWatch) {
1558
this._agentService.onResourceWatchUnsubscribed(sub.uri);