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 2014/09/28 18:13:04 UTC
[3/3] git commit: Flush stream after debugging info.
Flush stream after debugging info.
Project: http://git-wip-us.apache.org/repos/asf/jena/repo
Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/16fd2602
Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/16fd2602
Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/16fd2602
Branch: refs/heads/master
Commit: 16fd2602607ab3c91c61c2e98ada365cf9eb54a9
Parents: f786f7b
Author: Andy Seaborne <an...@apache.org>
Authored: Sun Sep 28 17:11:38 2014 +0100
Committer: Andy Seaborne <an...@apache.org>
Committed: Sun Sep 28 17:11:38 2014 +0100
----------------------------------------------------------------------
.../java/org/apache/jena/atlas/iterator/Iter.java | 18 ++++++++++--------
1 file changed, 10 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/jena/blob/16fd2602/jena-arq/src/main/java/org/apache/jena/atlas/iterator/Iter.java
----------------------------------------------------------------------
diff --git a/jena-arq/src/main/java/org/apache/jena/atlas/iterator/Iter.java b/jena-arq/src/main/java/org/apache/jena/atlas/iterator/Iter.java
index d74a141..03cd674 100644
--- a/jena-arq/src/main/java/org/apache/jena/atlas/iterator/Iter.java
+++ b/jena-arq/src/main/java/org/apache/jena/atlas/iterator/Iter.java
@@ -621,14 +621,16 @@ public class Iter<T> implements Iterable<T>, Iterator<T> {
* occurs when the returned iterator is used
*/
public static <T> Iterator<T> debug(final PrintStream out, Iterator<T> stream) {
- Transform<T, T> x = new Transform<T, T>() {
- @Override
- public T convert(T item) {
- out.println(item) ;
- return item ;
- }
- } ;
- return map(stream, x) ;
+ try {
+ Transform<T, T> x = new Transform<T, T>() {
+ @Override
+ public T convert(T item) {
+ out.println(item) ;
+ return item ;
+ }
+ } ;
+ return map(stream, x) ;
+ } finally { out.flush() ; }
}
/** Print an iterator (destructive) */