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