code: def get(self, timeout):
          
  
          # At first get we return a ping so the client immediately receives data
          if self._first:
              self._first = False
              return ("ping", PingStats.get(), {})
  
          try:
              (action, msg, kwargs) = yield from asyncio.wait_for(super().get(), timeout)
          except asyncio.futures.TimeoutError:
              return ("ping", PingStats.get(), {})
          return (action, msg, kwargs)
docs: When timeout is expire we send a ping notification with server information