code: @Override
      public void awaitCompletion() {
          while (!hydratedQueue.isEmpty()) {
              HydratedPojo<?> hydratedPojo = hydratedQueue.remove();
              if(!Futures.getUnchecked(hydratedPojo.getFuture())) {
                  throw new PojoNotFoundException(hydratedPojo.getBinding(), hydratedPojo.getTableName(), hydratedPojo.getKeys());
              }
          }
      }
docs: ----------------------------------------------------------------------------------------------------------------------