JENA-1011: clean up by calling .finish.
Project: http://git-wip-us.apache.org/repos/asf/jena/repo Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/4237973d Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/4237973d Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/4237973d Branch: refs/heads/JENA-491-construct-quads Commit: 4237973df8cd9c31912f3fce4fccb71365d0787c Parents: 7bd750c Author: Andy Seaborne <[email protected]> Authored: Thu Aug 20 19:14:16 2015 +0100 Committer: Andy Seaborne <[email protected]> Committed: Thu Aug 20 19:18:15 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/jena/riot/lang/TestPipedRDFIterators.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/jena/blob/4237973d/jena-arq/src/test/java/org/apache/jena/riot/lang/TestPipedRDFIterators.java ---------------------------------------------------------------------- diff --git a/jena-arq/src/test/java/org/apache/jena/riot/lang/TestPipedRDFIterators.java b/jena-arq/src/test/java/org/apache/jena/riot/lang/TestPipedRDFIterators.java index 1fcb228..3b6e4e5 100644 --- a/jena-arq/src/test/java/org/apache/jena/riot/lang/TestPipedRDFIterators.java +++ b/jena-arq/src/test/java/org/apache/jena/riot/lang/TestPipedRDFIterators.java @@ -480,7 +480,6 @@ public class TestPipedRDFIterators { /** * Tests attempting to access the iterator after the producer dies */ - @Test(expected = RiotException.class) public void streamed_state_bad_02() { final PipedRDFIterator<Triple> it = new PipedRDFIterator<>(); @@ -493,6 +492,7 @@ public class TestPipedRDFIterators { out.triple(Triple.create(org.apache.jena.graph.NodeFactory.createURI("urn:s"), org.apache.jena.graph.NodeFactory.createURI("urn:p"), org.apache.jena.graph.NodeFactory.createURI("urn:o"))); + out.finish() ; throw new RuntimeException("die!"); } }); @@ -510,9 +510,9 @@ public class TestPipedRDFIterators { Assert.assertTrue(it.hasNext()); it.next(); - - // Should throw a RiotException + // Should not throw a RiotException it.hasNext(); + } /**
