Skip to content

Commit 759c32a

Browse files
committed
fix: errors after stream starts
1 parent ad5be19 commit 759c32a

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

src/backend/src/modules/puterai/AIChatService.js

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -553,7 +553,17 @@ class AIChatService extends BaseService {
553553
stream,
554554
});
555555

556-
ret.result.value.init_chat_stream({ chatStream });
556+
(async () => {
557+
try {
558+
await ret.result.value.init_chat_stream({ chatStream });
559+
} catch (e) {
560+
stream.write(JSON.stringify({
561+
type: 'error',
562+
message: e.message,
563+
}) + '\n');
564+
stream.end();
565+
}
566+
})();
557567

558568
return retval;
559569
}

0 commit comments

Comments
 (0)