code: async def _do_ping(self):
          
          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
docs: Task that ensures Pings are sent periodically to the distant server
          :return: