Fix replaychat async startlisten
This commit is contained in:
@@ -13,6 +13,8 @@ __all__ = ["core_async","core_multithread","processors"]
|
|||||||
from .api import (
|
from .api import (
|
||||||
LiveChat,
|
LiveChat,
|
||||||
LiveChatAsync,
|
LiveChatAsync,
|
||||||
|
ReplayChat,
|
||||||
|
ReplayChatAsync,
|
||||||
ChatProcessor,
|
ChatProcessor,
|
||||||
CompatibleProcessor,
|
CompatibleProcessor,
|
||||||
SimpleDisplayProcessor,
|
SimpleDisplayProcessor,
|
||||||
|
|||||||
@@ -122,7 +122,7 @@ class ReplayChatAsync:
|
|||||||
else:
|
else:
|
||||||
listen_task.add_done_callback(self._done_callback)
|
listen_task.add_done_callback(self._done_callback)
|
||||||
|
|
||||||
def _startlisten(self):
|
async def _startlisten(self):
|
||||||
"""最初のcontinuationパラメータを取得し、
|
"""最初のcontinuationパラメータを取得し、
|
||||||
_listenループのタスクを作成し開始する
|
_listenループのタスクを作成し開始する
|
||||||
"""
|
"""
|
||||||
@@ -237,7 +237,7 @@ class ReplayChatAsync:
|
|||||||
data = self.processor.process(items)
|
data = self.processor.process(items)
|
||||||
await callback(data)
|
await callback(data)
|
||||||
|
|
||||||
def get(self):
|
async def get(self):
|
||||||
""" bufferからデータを取り出し、processorに投げ、
|
""" bufferからデータを取り出し、processorに投げ、
|
||||||
加工済みのチャットデータを返す。
|
加工済みのチャットデータを返す。
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user