1408
*/
1409
private _syncPendingMessages(chatChannel: ProtocolURI): void {
1410
>
const sessionChannel = parseRequiredSessionUriFromChatUri(chatChannel);
agentSideEffects.ts
1411
>
const state = this._stateManager.getSessionState(chatChannel);
1412
>
if (!state) {
1413
return;
1414
}
1416
>
agent?.setPendingMessages?.(
1417
>
URI.parse(chatChannel),
1418
>
state.steeringMessage,
1419
>
[],
1420
>
);
1421
>
1422
>
// Steering message removal is now dispatched by the agent
1423
>
// via the 'steering_consumed' progress event once the message
1424
>
// has actually been sent to the model.
1425
>
1426
>
// If the session is idle, try to consume the next queued message
1427
>
this._tryConsumeNextQueuedMessage(chatChannel);
1428
>
}
1429
1430
/**