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()
Modified test setup that syncs with ipython namespace
dataset/ETHPy150Open pika/pika/tests/acceptance/async_test_base.py/AsyncTestCase.on_timeout--crossover with--dataset/ETHPy150Open ipython/ipython-py3k/IPython/testing/plugin/ipdoctest.py/DocTestCase.setUp