diff src/main/java/alice/jungle/persistent/PersistentChangeListReader.java @ 116:895ab2907db3

Modified pom.xml
author one
date Fri, 20 Dec 2013 20:47:35 +0900
parents f42f2e6b31de
children f64ff5bd66f5
line wrap: on
line diff
--- a/src/main/java/alice/jungle/persistent/PersistentChangeListReader.java	Fri Dec 20 06:51:35 2013 +0900
+++ b/src/main/java/alice/jungle/persistent/PersistentChangeListReader.java	Fri Dec 20 20:47:35 2013 +0900
@@ -3,6 +3,7 @@
 import java.io.EOFException;
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.Iterator;
 
 import org.msgpack.MessagePack;
 
@@ -13,7 +14,7 @@
 public class PersistentChangeListReader  implements ChangeListReader {
 	
 	private InputStream in;
-	MessagePack msgpack = PersistentJournal.getMessagePack();
+	MessagePack msgpack = PersistentJournal.getMsgPackInstance();
 
 	public PersistentChangeListReader() {
 		in = null;
@@ -42,4 +43,29 @@
 		}
 		return null;
 	}
+
+	@Override
+	public Iterator<ChangeList> iterator() {
+		return new Iterator<ChangeList>() {
+
+			@Override
+			public boolean hasNext() {
+				try {
+					return in.available() != 0;
+				} catch (IOException e) {
+					return false;
+				}
+			}
+
+			@Override
+			public ChangeList next() {
+				return read();
+			}
+
+			@Override
+			public void remove() {
+				
+			}
+		};
+	}
 }