async def _do_ping(self):
        """
        Task that ensures Pings are sent periodically to the distant server
        :return:
        """
        try:
            while True:
                await asyncio.sleep(1)
                if self._ping_count > 10:
                    await self._reconnect()
                else:
                    self._ping_count += 1
                    await ZMQUtils.send(self._socket, Ping())
        except asyncio.CancelledError:
            return
        except KeyboardInterrupt:
            return
Task that ensures Pings are sent periodically to the distant server
        :return: