def _handle_response(self, obj: Dict) -> None:
req_id = obj.get('id')
if req_id is not None:
future = self._futures.get(req_id)
if future and not future.cancelled():
future.set_result(obj)
method = obj.get('method')
if method is not None:
callback = self._callbacks.get(method)
if callback is not None:
ret = callback(obj)
if inspect.isawaitable(ret):
await ret
评论列表
文章目录