def recv_until_string(self, expected_string):
ws_result = []
ws_instance = self._tab.get("ws_instance")
while True:
try:
result = ws_instance.recv()
except websocket.WebSocketTimeoutException:
return ws_result
if self._debug:
print("[DEBUG] result: {0}".format(result))
if not result:
return ws_result
# ????
ws_result.append(result)
# ?????????
formatted_result = json.loads(result)
event_name = formatted_result.get("method")
params = formatted_result.get("params")
self._call_event_listener(event_name, params)
# ??????
if expected_string in result:
break
return ws_result
评论列表
文章目录