

def it_should_raise_error_in_connection_methods(self):
    try:
        self.wait_for(self.channel.declare_queue('some.queue'))
    except exceptions.ConnectionLostError as err:
        assert (type(err) == exceptions.ConnectionLostError)
    else:
        assert False, 'ConnectionLostError not raised'

dataset/ETHPy150Open benjamin-hodgson/asynqp/test/connection_tests.py WhenServerClosesTransportWithoutConnectionClose.it_should_raise_error_in_connection_methods/original