Method deserializeGetsWithResponse

test/TestMultiAction.java:1036–1074

()

//  }
  
  @Test
  public void deserializeGetsWithResponse() throws Exception {
    final List<ResultOrException> results = new ArrayList<ResultOrException>(2);
    final List<KeyValue> kvs = new ArrayList<KeyValue>(2);
    kvs.add(new KeyValue(KEY, FAMILY, QUALIFIER, 1, VALUE));
    kvs.add(new KeyValue(KEY, FAMILY, QUALIFIER, 2, VALUE));
    results.add(PBufResponses.kvsToROE(kvs, 0));
    results.add(PBufResponses.kvsToROE(kvs, 1));

    GetRequest get1 = new GetRequest(TABLE, KEY, FAMILY, QUALIFIER);
    get1.region = region;
    GetRequest get2 = new GetRequest(TABLE, KEY, FAMILY, "myqual".getBytes());
    get2.region = region;
    
    MultiAction multi = new MultiAction();
    multi.add(get1);
    multi.add(get2);
    
    final MultiAction.Response decoded = 
        (MultiAction.Response)multi.deserialize(
            PBufResponses.encodeResponse(
                PBufResponses.generateMultiActionResponse(results)), 0);
    
    assertEquals(2, decoded.size());
    
    Object result1 = decoded.result(0);
    assertTrue(result1 instanceof ArrayList<?>);
    ArrayList<KeyValue> result1_cells = (ArrayList<KeyValue>)(result1);
    assertEquals(2, result1_cells.size());
    assertEquals(1, result1_cells.get(0).timestamp());
    assertEquals(2, result1_cells.get(1).timestamp());
    
    Object result2 = decoded.result(1);
    assertTrue(result2 instanceof ArrayList<?>);
    ArrayList<KeyValue> result2_cells = (ArrayList<KeyValue>)(result2);
    assertEquals(2, result2_cells.size());
    assertEquals(1, result2_cells.get(0).timestamp());
    assertEquals(2, result2_cells.get(1).timestamp());
  }
  
  @Test
  public void deserializeGetsWithResponseException() throws Exception {