Revision 45805
Added by Sandro La Bruzzo over 7 years ago
FilterResolvedRecordJobNode.java | ||
---|---|---|
43 | 43 |
final Iterable<String> resultIterator = () -> DnetStreamSupport.generateStreamFromIterator(resolverStore.getAllRecords().iterator()) |
44 | 44 |
.map(record -> { |
45 | 45 |
final ObjectType type = record.getType(); |
46 |
if (type == null || !type.toString().equals(this.type)) |
|
47 |
return "<JUNK/>"; |
|
48 |
final String resultXML = String.format(recordTemplate, resolverSerializer.serializeToXML(record)); |
|
49 |
return resultXML; |
|
46 |
if (type == null || !type.toString().equals(this.type)) { |
|
47 |
return "<JUNK/>"; |
|
48 |
} |
|
49 |
final String resultXML = String.format(recordTemplate, resolverSerializer.serializeToXML(record)); |
|
50 |
if ("10.1594/pangaea.695501".equals(record.getPid())) { |
|
51 |
System.out.println(record.toString()); |
|
52 |
System.out.println(resultXML); |
|
53 |
} |
|
54 |
return resultXML; |
|
50 | 55 |
}).iterator(); |
51 | 56 |
|
52 | 57 |
final ResultSet<String> resultSet = resultSetFactory.createResultSet(resultIterator); |
Also available in: Unified diff
fixed generation of resolved Record