Mercurial > hg > Members > nobuyasu > jungle-network
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() { + + } + }; + } }