Revision 50231
Added by Claudio Atzori over 6 years ago
| modules/dnet-msro-service/trunk/src/main/java/eu/dnetlib/msro/workflows/nodes/objectStore/DownloadIntoObjectStoreJobNode.java | ||
|---|---|---|
| 75 | 75 |
job.getParameters().put("mime", getMimeType());
|
| 76 | 76 |
final Iterator<String> client = resultSetClientFactory.getClient(eprS).iterator(); |
| 77 | 77 |
|
| 78 |
final W3CEndpointReference epr = iterableResultSetFactory.createIterableResultSet(new Iterable<String>() {
|
|
| 79 |
|
|
| 80 |
@Override |
|
| 81 |
public Iterator<String> iterator() {
|
|
| 82 |
return new MetadataObjectIterator(client, "//*[local-name()='objIdentifier']", "xml"); |
|
| 83 |
} |
|
| 84 |
}); |
|
| 78 |
final W3CEndpointReference epr = iterableResultSetFactory.createIterableResultSet( |
|
| 79 |
() -> new MetadataObjectIterator(client, "//*[local-name()='objIdentifier']", "xml")); |
|
| 85 | 80 |
this.progressProvider = processCountingResultSetFactory.createProgressProvider(token.getProcess(), epr); |
| 86 | 81 |
job.getParameters().put("epr", progressProvider.getEpr().toString());
|
| 87 | 82 |
|
Also available in: Unified diff
use java8 streams