@Override
    protected void sendFillRequest(Result result, String summaryClass) {
        partialSummaryHandler.wantToFill(result, summaryClass);
        if (partialSummaryHandler.resultAlreadyFilled()) {
            result.getQuery().trace(false, 3, "Skipping fill of ", summaryClass, " as result is already filled");
            return;
        }
        ListMap<Integer, FastHit> hitsByNode = hitsByNode(result);
        int queueSize = Math.max(hitsByNode.size(), resourcePool.knownNodeIds().size());
        responses = new LinkedBlockingQueue<>(queueSize);
        sendFillRequestByNode(result, summaryClass, hitsByNode);
    }
The number of responses we should receive (and process) before this is complete
container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java