NetworkTransport: be able to handle multiple events in one socket.recv, the method still has to be better

This commit is contained in:
norohind 2022-11-13 15:02:41 +03:00
parent 507ad8878c
commit ac22b9633e
Signed by: norohind
GPG Key ID: 01C3BECC26FB59E1

View File

@ -58,6 +58,11 @@ class NetworkTransport(TransportABC):
self._close_conn(conn)
return
for data_part in data.split(b'\n'):
if len(data_part) != 0:
self._handle_received_event(data_part, conn)
def _handle_received_event(self, data: bytes, conn: socket.socket):
try:
event_dict = json.loads(data)
event_name = event_dict['event']