You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by rv...@apache.org on 2013/01/29 13:18:15 UTC
svn commit: r1439851 - in
/jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang:
PipedRDFIterator.java PipedRDFStream.java
Author: rvesse
Date: Tue Jan 29 12:18:15 2013
New Revision: 1439851
URL: http://svn.apache.org/viewvc?rev=1439851&view=rev
Log:
Remove a spurios set of closedByReader in the hasNext() method of the PipedRDFIterator
Modified:
jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java
jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFStream.java
Modified: jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java?rev=1439851&r1=1439850&r2=1439851&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java (original)
+++ jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java Tue Jan 29 12:18:15 2013
@@ -173,9 +173,9 @@ public class PipedRDFIterator<T> impleme
}
}
+ // When the end marker is seen set slot to null
if (slot == endMarker)
{
- closedByReader = true ;
slot = null ;
return false ;
}
Modified: jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFStream.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFStream.java?rev=1439851&r1=1439850&r2=1439851&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFStream.java (original)
+++ jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFStream.java Tue Jan 29 12:18:15 2013
@@ -23,6 +23,7 @@ import org.apache.jena.riot.system.Strea
/**
* Abstract implementation of a producer class that implements {@code StreamRDF};
* use one of the concrete implementations that match the RDF primitive you are using.
+ * @param <T> Type corresponding to a supported RDF primitive
*
* @see PipedTriplesStream
* @see PipedQuadsStream