def on_closed(self, connection, reply_code, reply_text):
        self.logger.info('on_closed: %r %r %r', connection,
                         reply_code, reply_text)
        self._stop()
called when the connection has finished closing
dataset/ETHPy150Open pika/pika/tests/acceptance/async_test_base.py/AsyncTestCase.on_closed