def recv(self):
n = 0
self._soc.settimeout(0.1)
try:
got = self._soc.recv()
while 1:
try:
val = json.loads(got)
self._handle_event(val['method'], val['params'])
n += 1
break
except json.JSONDecodeError as e:
self._handle_event(got[:e.pos])
n += 1
got = got[e.pos:]
except websocket.WebSocketTimeoutException:
pass
self._soc.settimeout(None)
return n
评论列表
文章目录