中断消息提示错误

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");
});

Beginne damit, den im Issue gezeigten Subscription-Ablauf zu reproduzieren, insbesondere den Zweig CONVERSATION_CHAT_IN_PROGRESS und seinen Aufruf von cancelSession. Untersuche, wie die Abbruchantwort erzeugt und protokolliert wird, und bestätige anschließend, dass die Unterbrechungsnachricht dem erwarteten Verhalten entspricht; im Issue werden keine Quelldatei und kein Test genannt.

Vom Indexierungsmodell aus dem Issue-Text verfasst.