|
20 | 20 | import java.net.URI; |
21 | 21 | import java.net.URISyntaxException; |
22 | 22 | import java.util.Collection; |
23 | | -import java.util.HashSet; |
24 | | -import java.util.List; |
25 | 23 | import java.util.Optional; |
26 | 24 | import java.util.Set; |
27 | 25 | import java.util.function.BiConsumer; |
|
44 | 42 | import org.slf4j.Logger; |
45 | 43 | import org.slf4j.LoggerFactory; |
46 | 44 |
|
47 | | -import com.fasterxml.jackson.core.type.TypeReference; |
48 | | -import com.fasterxml.jackson.databind.ObjectMapper; |
49 | | - |
50 | 45 | import jakarta.json.JsonObject; |
51 | 46 | import jakarta.json.JsonString; |
52 | 47 | import jakarta.json.JsonStructure; |
@@ -125,6 +120,10 @@ private void parse(InputStream in, Reader reader, String baseURI) |
125 | 120 | throws RDFParseException, RDFHandlerException, IOException { |
126 | 121 | clear(); |
127 | 122 |
|
| 123 | + if (rdfHandler != null) { |
| 124 | + rdfHandler.startRDF(); |
| 125 | + } |
| 126 | + |
128 | 127 | try { |
129 | 128 |
|
130 | 129 | Document document = getDocument(in, reader); |
@@ -179,6 +178,9 @@ private void parse(InputStream in, Reader reader, String baseURI) |
179 | 178 | } |
180 | 179 |
|
181 | 180 | RDFHandler rdfHandler = getRDFHandler(); |
| 181 | + if (rdfHandler != null) { |
| 182 | + extractPrefixes(document, rdfHandler::handleNamespace); |
| 183 | + } |
182 | 184 |
|
183 | 185 | JsonLd.toRdf(document).options(opts).base(baseURI).get(new RdfConsumer<>() { |
184 | 186 | @Override |
@@ -242,7 +244,7 @@ public Literal createLangString(String value, String lang) { |
242 | 244 | }); |
243 | 245 |
|
244 | 246 | if (rdfHandler != null) { |
245 | | - extractPrefixes(document, rdfHandler::handleNamespace); |
| 247 | + rdfHandler.endRDF(); |
246 | 248 | } |
247 | 249 |
|
248 | 250 | } catch (no.hasmac.jsonld.JsonLdError e) { |
|
0 commit comments