@@ -9,7 +9,7 @@ import { ILogService } from 'vs/platform/log/common/log';
9
9
import { ExtHostChatProviderShape , IMainContext , MainContext , MainThreadChatProviderShape } from 'vs/workbench/api/common/extHost.protocol' ;
10
10
import * as typeConvert from 'vs/workbench/api/common/extHostTypeConverters' ;
11
11
import type * as vscode from 'vscode' ;
12
- import { AsyncProgress } from 'vs/platform/progress/common/progress' ;
12
+ import { Progress } from 'vs/platform/progress/common/progress' ;
13
13
import { IChatMessage , IChatResponseFragment } from 'vs/workbench/contrib/chat/common/chatProvider' ;
14
14
import { ExtensionIdentifier , ExtensionIdentifierMap } from 'vs/platform/extensions/common/extensions' ;
15
15
import { AsyncIterableSource } from 'vs/base/common/async' ;
@@ -119,12 +119,12 @@ export class ExtHostChatProvider implements ExtHostChatProviderShape {
119
119
if ( ! data ) {
120
120
return ;
121
121
}
122
- const progress = new AsyncProgress < vscode . ChatResponseFragment > ( async fragment => {
122
+ const progress = new Progress < vscode . ChatResponseFragment > ( async fragment => {
123
123
if ( token . isCancellationRequested ) {
124
124
this . _logService . warn ( `[CHAT](${ data . extension . value } ) CANNOT send progress because the REQUEST IS CANCELLED` ) ;
125
125
return ;
126
126
}
127
- await this . _proxy . $handleProgressChunk ( requestId , { index : fragment . index , part : fragment . part } ) ;
127
+ this . _proxy . $handleProgressChunk ( requestId , { index : fragment . index , part : fragment . part } ) ;
128
128
} ) ;
129
129
130
130
return data . provider . provideChatResponse ( messages . map ( typeConvert . ChatMessage . to ) , options , progress , token ) ;
0 commit comments