write后及时flush,避免windows退出无法触发绑定的信号监听器
This commit is contained in:
parent
788c8cba9d
commit
77d4854530
@ -56,6 +56,7 @@ class XMLWriter(IOutput):
|
|||||||
cur_time * 1000, message.user().id, message.user().nickname, message.content
|
cur_time * 1000, message.user().id, message.user().nickname, message.content
|
||||||
)
|
)
|
||||||
fd.write(_c)
|
fd.write(_c)
|
||||||
|
fd.flush()
|
||||||
|
|
||||||
def gift_output(self, message):
|
def gift_output(self, message):
|
||||||
fd = self._get_fd_by_room_id(message.room_id)
|
fd = self._get_fd_by_room_id(message.room_id)
|
||||||
@ -67,6 +68,7 @@ class XMLWriter(IOutput):
|
|||||||
message.user().nickname, message.gift.name, message.instance.repeatCount
|
message.user().nickname, message.gift.name, message.instance.repeatCount
|
||||||
)
|
)
|
||||||
fd.write(_c)
|
fd.write(_c)
|
||||||
|
fd.flush()
|
||||||
|
|
||||||
def terminate(self):
|
def terminate(self):
|
||||||
print("保存所有弹幕文件中...")
|
print("保存所有弹幕文件中...")
|
||||||
|
Reference in New Issue
Block a user