JENA-1011 : Make finish idempotent based on closedByProducer.
Project: http://git-wip-us.apache.org/repos/asf/jena/repo Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/503bdcfd Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/503bdcfd Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/503bdcfd Branch: refs/heads/master Commit: 503bdcfdff3c46b3887434ae658e213f6bf1b982 Parents: c08f31d Author: Andy Seaborne <[email protected]> Authored: Thu Aug 20 19:11:55 2015 +0100 Committer: Andy Seaborne <[email protected]> Committed: Thu Aug 20 19:17:56 2015 +0100 ---------------------------------------------------------------------- .../src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/jena/blob/503bdcfd/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java ---------------------------------------------------------------------- diff --git a/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java b/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java index 68395af..3259b9d 100644 --- a/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java +++ b/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java @@ -374,6 +374,8 @@ public class PipedRDFIterator<T> implements Iterator<T>, Closeable { * and error out. */ protected void finish() { + if ( closedByProducer ) + return ; receive(endMarker); closedByProducer = true; }
