Revision 48701
Added by Sandro La Bruzzo over 6 years ago
| MDStoreRetriever.java | ||
|---|---|---|
| 35 | 35 |
log.debug("bulk deliver of mdId: " + mdId);
|
| 36 | 36 |
try {
|
| 37 | 37 |
return DnetStreamSupport.generateStreamFromIterator(dao.readMDStore(mdId).iterate().iterator()); |
| 38 |
} catch (MDStoreServiceException e) {
|
|
| 39 |
throw new RuntimeException(e);
|
|
| 38 |
} catch (Throwable e) {
|
|
| 39 |
throw new RuntimeException(e);
|
|
| 40 | 40 |
} |
| 41 | 41 |
}).reduce(Stream::concat).orElseGet(Stream::empty).iterator(); |
| 42 | 42 |
} |
Also available in: Unified diff
Upgraded incremental harvesting and other stuff