中断消息提示错误

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