Method handle_msg

app/contacts/contact_udp.py:40–46

()

    def datagram_received(self, data, addr):
        async def handle_msg():
            try:
                message = json.loads(data.decode())
                for handle in [h for h in self.handles if h.tag == message.pop('tag')]:
                    await handle.run(message, self.services, addr[0])
            except Exception as e:
                self.log.debug(e)
        asyncio.get_event_loop().create_task(handle_msg())