'Test a single connection with pipelined requests.'

def test_single_connection_pipelined_requests(self):

    conn = self.get_connection()
    query = 'SELECT    keyspace_name    FROM    system.schema_keyspaces    LIMIT    1'
    responses = ([False] * 100)
    event = Event()
    def cb(response_list, request_num, *args, **kwargs):
        response_list[request_num] = True
        if all(response_list):
            conn.close()
            event.set()
    for i in range(100):
        conn.send_msg(QueryMessage(query=query, consistency_level=ConsistencyLevel.ONE), request_id=i, cb=partial(cb, responses, i))
    event.wait()
