@Test
public void testReadModifyWriteRowAsync() throws Exception {

  ReadModifyWriteRow mutation = ReadModifyWriteRow.create(TABLE_ID, ROW_KEY);
  Row expectedRow =
      Row.create(
          ByteString.copyFromUtf8(ROW_KEY),
          ImmutableList.of(RowCell.create(COL_FAMILY, QUALIFIER_1, TIMESTAMP, LABELS, VALUE_1)));
  when(dataClientV2.readModifyWriteRowAsync(mutation)).thenReturn(immediateFuture(expectedRow));
  Row actualRow = dataGCJClient.readModifyWriteRowAsync(mutation).get();
  assertEquals(expectedRow, actualRow);
  verify(dataClientV2).readModifyWriteRowAsync(mutation);
}