中断消息提示错误

stream.subscribeOn(Schedulers.io())
.subscribe(
event -> {
if (ChatEventType.CONVERSATION_CHAT_IN_PROGRESS.equals(event.getEvent())) {
log.info("接收到的消息：{}", event.getChat());
log.info("GitHub测试终端会话");
CancelChatResp cancelChatResp = cancelSession(event.getChat().getConversationID(), event.getChat().getID());
log.info("中断信息：{}", cancelChatResp.toString());
}
if (ChatEventType.CONVERSATION_CHAT_COMPLETED.equals(event.getEvent())) {
log.info("Token usage:{}", event.getChat().getUsage().getTokenCount());
cozeAPI.shutdownExecutor();
}
},
throwable -> {
log.error("Error occurred: {}", throwable.getMessage());
},
() -> {
log.info("done");
});

Commencez par reproduire le flux d’abonnement présenté dans l’issue, en particulier la branche CONVERSATION_CHAT_IN_PROGRESS et son appel à cancelSession. Examinez comment la réponse d’annulation est produite et journalisée, puis confirmez que le message d’interruption correspond au comportement attendu ; l’issue ne nomme aucun fichier source ni aucun test.

Rédigé par le modèle d'indexation à partir du texte de l'issue.