def parse_message(self, message):
tag, _, data = message.partition(" ")
if tag in CLIENT:
parsed = (CLIENT[tag],)
elif tag in SERVER:
parsed = (SERVER[tag],)
else:
raise ValueError("Unknown message type %s" % tag)
decoder = JSONDecoder()
while data:
data = data.lstrip()
try:
decoded, end = decoder.raw_decode(data)
except JSONDecodeError:
break
else:
parsed += (decoded,)
data = data[end:]
return parsed
评论列表
文章目录