

def given_I_wrote_the_protocol_header(self):
    connection_info = {
        'username': 'guest',
        'password': 'guest',
        'virtual_host': '/',
    }
    self.async_partial(open_connection(self.loop, self.transport, self.protocol, self.dispatcher, connection_info))

dataset/ETHPy150Open benjamin-hodgson/asynqp/test/connection_tests.py WhenRespondingToConnectionStart.given_I_wrote_the_protocol_header/original