async def _tcp_on_closed(self):
        """Invoked when the socket is closed."""
        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()