code: async def _tcp_on_closed(self):
          
          LOGGER.warning('Not connected to statsd, connecting in %s seconds',
                         self._tcp_reconnect_sleep)
          await asyncio.sleep(self._tcp_reconnect_sleep)
          self._sock = self._tcp_socket()
docs: Invoked when the socket is closed.