X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.jcr%2Fsrc%2Forg%2Fargeo%2Fjcr%2Ffs%2FNodeDirectoryStream.java;fp=org.argeo.jcr%2Fsrc%2Forg%2Fargeo%2Fjcr%2Ffs%2FNodeDirectoryStream.java;h=dbf6745360a7928b7d910bb342358ed2d33a1509;hb=d8037dd6a59ff5d38d7c7182a9ef6c26c8001a4f;hp=0000000000000000000000000000000000000000;hpb=a5c66ac837e01e447161c3d73fe35eadc26cf304;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.jcr/src/org/argeo/jcr/fs/NodeDirectoryStream.java b/org.argeo.jcr/src/org/argeo/jcr/fs/NodeDirectoryStream.java
new file mode 100644
index 000000000..dbf674536
--- /dev/null
+++ b/org.argeo.jcr/src/org/argeo/jcr/fs/NodeDirectoryStream.java
@@ -0,0 +1,63 @@
+package org.argeo.jcr.fs;
+
+import java.io.IOException;
+import java.nio.file.DirectoryStream;
+import java.nio.file.Path;
+import java.util.Iterator;
+
+import javax.jcr.Node;
+import javax.jcr.NodeIterator;
+
+public class NodeDirectoryStream implements DirectoryStream<Path> {
+	private final JcrFileSystem fs;
+	private final NodeIterator nodeIterator;
+	private final Filter<? super Path> filter;
+
+	public NodeDirectoryStream(JcrFileSystem fs, NodeIterator nodeIterator, Filter<? super Path> filter) {
+		this.fs = fs;
+		this.nodeIterator = nodeIterator;
+		this.filter = filter;
+	}
+
+	@Override
+	public void close() throws IOException {
+	}
+
+	@Override
+	public Iterator<Path> iterator() {
+		return new Iterator<Path>() {
+			private JcrPath next = null;
+
+			@Override
+			public synchronized boolean hasNext() {
+				if (next != null)
+					return true;
+				nodes: while (nodeIterator.hasNext()) {
+					try {
+						Node node = nodeIterator.nextNode();
+						next = new JcrPath(fs, node);
+						if (filter != null) {
+							if (filter.accept(next))
+								break nodes;
+						} else
+							break nodes;
+					} catch (Exception e) {
+						throw new JcrFsException("Could not get next path", e);
+					}
+				}
+				return next != null;
+			}
+
+			@Override
+			public synchronized Path next() {
+				if (!hasNext())// make sure has next has been called
+					return null;
+				JcrPath res = next;
+				next = null;
+				return res;
+			}
+
+		};
+	}
+
+}