// timer for the total serialization time
final StopWatch stopWatch = new StopWatch();
final EventExecutorGroup executorService = ctx.executor();
final Future<?> iteration = executorService.submit((Callable<Void>) () -> {
logger.debug("Preparing to iterate results from - {} - in thread [{}]", requestMessage, Thread.currentThread().getName());
stopWatch.start();
List<Object> aggregate = new ArrayList<>(resultIterationBatchSize);