You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2025/03/23 16:50:51 UTC

(jena) branch main updated: Update QueryIteratorWrapper to use performClose and performRequestCancel.

This is an automated email from the ASF dual-hosted git repository.

andy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/jena.git


The following commit(s) were added to refs/heads/main by this push:
     new 4fe909bce0 Update QueryIteratorWrapper to use performClose and performRequestCancel.
4fe909bce0 is described below

commit 4fe909bce00984a6239eb5313442e7e3fab85221
Author: Claus Stadler <Ra...@googlemail.com>
AuthorDate: Sun Mar 16 19:53:05 2025 +0100

    Update QueryIteratorWrapper to use performClose and performRequestCancel.
---
 .../jena/sparql/engine/iterator/QueryIteratorWrapper.java     | 11 +++--------
 1 file changed, 3 insertions(+), 8 deletions(-)

diff --git a/jena-arq/src/main/java/org/apache/jena/sparql/engine/iterator/QueryIteratorWrapper.java b/jena-arq/src/main/java/org/apache/jena/sparql/engine/iterator/QueryIteratorWrapper.java
index 2f524a5e4d..595fba812b 100644
--- a/jena-arq/src/main/java/org/apache/jena/sparql/engine/iterator/QueryIteratorWrapper.java
+++ b/jena-arq/src/main/java/org/apache/jena/sparql/engine/iterator/QueryIteratorWrapper.java
@@ -44,17 +44,13 @@ public class QueryIteratorWrapper extends QueryIteratorBase {
 
     @Override
     protected void closeIterator() {
-        if ( iterator != null ) {
-            iterator.close();
-            iterator = null;
-        }
+        performClose(iterator);
+        iterator = null;
     }
 
     @Override
     protected void requestCancel() {
-        if ( iterator != null ) {
-            iterator.cancel();
-        }
+        performRequestCancel(iterator);
     }
 
     @Override
@@ -70,5 +66,4 @@ public class QueryIteratorWrapper extends QueryIteratorBase {
         out.decIndent();
         // out.println(Utils.className(this)+"/"+Utils.className(iterator)) ;
     }
-
 }