diff --git a/src/easynetwork/lowlevel/api_async/servers/datagram.py b/src/easynetwork/lowlevel/api_async/servers/datagram.py index b1f0eeff..acc2c073 100644 --- a/src/easynetwork/lowlevel/api_async/servers/datagram.py +++ b/src/easynetwork/lowlevel/api_async/servers/datagram.py @@ -185,13 +185,10 @@ async def handler(datagram: bytes, address: _T_Address, /) -> None: client = client_cache[address] except KeyError: client_cache[address] = client = _ClientToken(DatagramClientContext(address, self), _ClientData(backend)) - new_client_task = True - else: - new_client_task = client.data.state is None await client.data.push_datagram(datagram) - if new_client_task: + if client.data.state is None: del datagram client.data.mark_pending() await self.__client_coroutine(datagram_received_cb, client, task_group, default_context)