svn commit: r1439851 - in /jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/lang: PipedRDFIterator.java PipedRDFStream.java

[rvesse]

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