Revision 52520
Added by Claudio Atzori almost 6 years ago
| modules/dnet-collector-plugins/trunk/src/main/java/eu/dnetlib/data/collector/plugins/httpfilename/HTTPWithFileNameCollectorIterable.java | ||
|---|---|---|
| 67 | 67 |
} |
| 68 | 68 |
} |
| 69 | 69 |
|
| 70 |
return !(Objects.equals(last, TERMINATOR) || Objects.equals(last,null));
|
|
| 70 |
return !(Objects.equals(last, TERMINATOR)); |
|
| 71 | 71 |
} |
| 72 | 72 |
|
| 73 | 73 |
@Override |
| ... | ... | |
| 76 | 76 |
return last; |
| 77 | 77 |
} |
| 78 | 78 |
|
| 79 |
// @Override |
|
| 80 |
// public boolean hasNext() {
|
|
| 81 |
// |
|
| 82 |
// return !Objects.equals(last, TERMINATOR); |
|
| 83 |
// } |
|
| 84 |
// |
|
| 85 |
// @Override |
|
| 86 |
// public String next() {
|
|
| 87 |
// try {
|
|
| 88 |
// last = queue.poll(waitTime, TimeUnit.SECONDS); |
|
| 89 |
// if (Objects.equals(last, TERMINATOR)) {
|
|
| 90 |
// log.info("found terminator, omg!");
|
|
| 91 |
// } |
|
| 92 |
// } catch (InterruptedException e) {
|
|
| 93 |
// log.warn(String.format("could not find elements to consume for more than %s%s", waitTime, TimeUnit.SECONDS));
|
|
| 94 |
// throw new NoSuchElementException(e.getMessage()); |
|
| 95 |
// } |
|
| 96 |
// return last; |
|
| 97 |
// } |
|
| 98 |
|
|
| 99 | 79 |
}; |
| 100 | 80 |
} |
| 101 | 81 |
|
Also available in: Unified diff
cleanup