913
}
914
});
916
>
};
917
918
const trackNewCancellableRequest = () => {
919
>
const cancellableRequest = this.instantiationService.createInstance(CancellableRequest, new CancellationTokenSource(), undefined, undefined, undefined);
chatServiceImpl.ts
920
>
this._syntheticPendingRequests.add(cancellableRequest);
921
>
this._pendingRequests.set(model.sessionResource, cancellableRequest);
922
>
this.telemetryService.publicLog2<ChatPendingRequestChangeEvent, ChatPendingRequestChangeClassification>(ChatPendingRequestChangeEventName, { action: 'add', source: 'remoteSession', chatSessionId: chatSessionResourceToId(model.sessionResource) });
923
>
cancellationListener.value = createCancellationListener(cancellableRequest.cancellationTokenSource.token);
924
>
};
925
926
const ensureCancellationTracking = () => {
928
trackNewCancellableRequest();
929
}
931
932
if (lastRequest && !providedSession.isCompleteObs?.get()) {
934
>
}
935
936
// Handle server-initiated requests (e.g. consumed queued messages).