中断消息提示错误

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

Empieza reproduciendo el flujo de suscripción mostrado en el issue, especialmente la rama CONVERSATION_CHAT_IN_PROGRESS y su llamada a cancelSession. Inspecciona cómo se produce y registra la respuesta de cancelación y, después, confirma que el mensaje de interrupción coincide con el comportamiento esperado; el issue no especifica ningún archivo fuente ni prueba.

Escrito por el modelo de indexación a partir del texto del issue.