

def given_a_channel(self):
    task = self.loop.create_task(self.connection.open_channel())
    task.tick()
    self.server.send_method(1, spec.ChannelOpenOK(''))
    self.channel = self.wait_for(task)

dataset/ETHPy150Open benjamin-hodgson/asynqp/test/connection_tests.py WhenServerClosesTransportWithoutConnectionClose.given_a_channel/VarMisuse@27/32 `self`->`task`