

def given_a_closed_connection(self):
    t = asyncio.async(self.connection.close())
    t._log_destroy_pending = False
    self.tick()
    self.server.reset()

dataset/ETHPy150Open benjamin-hodgson/asynqp/test/connection_tests.py WhenAConnectionThatIsClosingReceivesAMethod.given_a_closed_connection/original