@Test
public void testAdd() throws Exception {

  dataClient = BigtableDataClient.create(settingsBuilder.build());
  BulkReadWrapper bulkReadWrapper = new BulkReadVeneerApi(dataClient, TABLE_ID);
  ApiFuture<Result> resultFuture1_1 = bulkReadWrapper.add(ByteString.copyFromUtf8("one"), null);
  ApiFuture<Result> resultFuture1_2 = bulkReadWrapper.add(ByteString.copyFromUtf8("two"), null);
  assertFalse(resultFuture1_1.isDone());
  Filters.Filter filter = Filters.FILTERS.key().regex("cf");
  ApiFuture<Result> secBatchResult1 = bulkReadWrapper.add(ByteString.copyFromUtf8("1"), filter);
  ApiFuture<Result> secBatchResult2 = bulkReadWrapper.add(ByteString.copyFromUtf8("2"), filter);
  bulkReadWrapper.sendOutstanding();
  resultFuture1_1.get();
  resultFuture1_2.get();
  secBatchResult1.get();
  secBatchResult2.get();
  // If one entry of the batch is resolved then another should also be
  assertTrue(resultFuture1_1.isDone());
  assertTrue(resultFuture1_2.isDone());
  assertTrue(secBatchResult1.isDone());
  assertTrue(secBatchResult2.isDone());
  assertEquals(2, fakeDataService.getReadRowsBatchCount());
}