Do not use async evaluation for last binding.

linkedfactory · Sep 2, 2024 · cf08b87 · cf08b87
1 parent c60d066
commit cf08b87
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/...tory.core/src/main/java/io/github/linkedfactory/core/rdf4j/kvin/KvinFederatedService.java b/...tory.core/src/main/java/io/github/linkedfactory/core/rdf4j/kvin/KvinFederatedService.java
@@ -110,13 +110,21 @@ public CloseableIteration<BindingSet, QueryEvaluationException> evaluate(
                 while (bindings.hasNext() && bindingSetList.size() < InnerJoinIterator.BATCH_SIZE) {
                     bindingSetList.add(bindings.next());
                 }
-                resultIters.add(new AsyncIterator<>(() -> ((BatchQueryEvaluationStep) precompiled)
-                        .evaluate(bindingSetList), executorService));
+                if (! bindings.hasNext()) {
+                    resultIters.add(((BatchQueryEvaluationStep) precompiled).evaluate(bindingSetList));
+                } else {
+                    resultIters.add(new AsyncIterator<>(() -> ((BatchQueryEvaluationStep) precompiled)
+                            .evaluate(bindingSetList), executorService));
+                }
             }
         } else {
             while (bindings.hasNext()) {
                 BindingSet bs = bindings.next();
-                resultIters.add(new AsyncIterator<>(() -> precompiled.evaluate(bs), executorService));
+                if (! bindings.hasNext()) {
+                    resultIters.add(precompiled.evaluate(bs));
+                } else {
+                    resultIters.add(new AsyncIterator<>(() -> precompiled.evaluate(bs), executorService));
+                }
             }
         }