def on_timeout(self):
        self.logger.error('%s timed out; on_timeout called at %s',
            self, datetime.utcnow())
        self.timeout = None  # the dispatcher should have removed it
        self._timed_out = True
        # initiate cleanup
        self.stop()
called when stuck waiting for connection to close
dataset/ETHPy150Open pika/pika/tests/acceptance/async_test_base.py/AsyncTestCase.on_timeout