Mercurial > hg > Members > nobuyasu > jungle-network

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

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Modified pom.xml
author one
date Fri, 20 Dec 2013 20:47:35 +0900
parents f42f2e6b31de
children f64ff5bd66f5
comparison
equal deleted inserted replaced
115:3f9c6ab43461 116:895ab2907db3
1 package alice.jungle.persistent; 1 package alice.jungle.persistent;
2 2
3 import java.io.EOFException; 3 import java.io.EOFException;
4 import java.io.IOException; 4 import java.io.IOException;
5 import java.io.InputStream; 5 import java.io.InputStream;
6 import java.util.Iterator;
6 7
7 import org.msgpack.MessagePack; 8 import org.msgpack.MessagePack;
8 9
9 import alice.jungle.operations.NetworkTreeOperationLog; 10 import alice.jungle.operations.NetworkTreeOperationLog;
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList; 11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader; 12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
12 13
13 public class PersistentChangeListReader implements ChangeListReader { 14 public class PersistentChangeListReader implements ChangeListReader {
14 15
15 private InputStream in; 16 private InputStream in;
16 MessagePack msgpack = PersistentJournal.getMessagePack(); 17 MessagePack msgpack = PersistentJournal.getMsgPackInstance();
17 18
18 public PersistentChangeListReader() { 19 public PersistentChangeListReader() {
19 in = null; 20 in = null;
20 } 21 }
21 22
40 41
41 } catch (IOException e) { 42 } catch (IOException e) {
42 } 43 }
43 return null; 44 return null;
44 } 45 }
46
47 @Override
48 public Iterator<ChangeList> iterator() {
49 return new Iterator<ChangeList>() {
50
51 @Override
52 public boolean hasNext() {
53 try {
54 return in.available() != 0;
55 } catch (IOException e) {
56 return false;
57 }
58 }
59
60 @Override
61 public ChangeList next() {
62 return read();
63 }
64
65 @Override
66 public void remove() {
67
68 }
69 };
70 }
45 } 71 }