

def when_client_closes_connection(self):
    task = asyncio.async(self.connection.close())
    self.tick()
    self.server.send_method(0, spec.ConnectionCloseOK())
    self.tick()
    self.tick()
    task.result()

dataset/ETHPy150Open benjamin-hodgson/asynqp/test/connection_tests.py WhenOpeningAChannelOnAClosedConnection.when_client_closes_connection/original