@Test
public void testAdd() throws ExecutionException, InterruptedException {

  when(delegate.add(Query.create(TABLE_ID).rowKey("row-key")))
      .thenReturn(ApiFutures.immediateFuture(FLAT_ROW));
  Result result = bulkReadWrapper.add(ByteString.copyFromUtf8("row-key"), null).get();
  assertArrayEquals(FLAT_ROW.getRowKey().toByteArray(), result.getRow());
  assertArrayEquals(FLAT_ROW_ADAPTER.adaptResponse(FLAT_ROW).rawCells(), result.rawCells());
  verify(delegate).add(Query.create(TABLE_ID).rowKey("row-key"));
}