protected void parseSynchronusly()

in commons-rdf-jena/src/main/java/org/apache/commons/rdf/jena/experimental/JenaRDFParser.java [65:93]

• 27 lines of code
• 7 McCabe index (conditional complexity)

    protected void parseSynchronusly() throws IOException {
        StreamRDF dest;
        final JenaRDF jenaRDF = getJenaFactory();
        if (getTargetGraph().isPresent() && getTargetGraph().get() instanceof JenaGraph) {
            final Graph jenaGraph = ((JenaGraph) getTargetGraph().get()).asJenaGraph();
            dest = StreamRDFLib.graph(jenaGraph);
        } else {
            if (generalizedConsumerQuad != null) {
                dest = jenaRDF.streamJenaToGeneralizedQuad(generalizedConsumerQuad);
            } else if (generalizedConsumerTriple != null) {
                dest = jenaRDF.streamJenaToGeneralizedTriple(generalizedConsumerTriple);
            } else {
                dest = JenaRDF.streamJenaToQuad(getRdfTermFactory().get(), getTarget());
            }
        }

        final Lang lang = getContentTypeSyntax().flatMap(jenaRDF::asJenaLang).orElse(null);
        final String baseStr = getBase().map(IRI::getIRIString).orElse(null);

        if (getSourceIri().isPresent()) {
                RDFParser.source(getSourceIri().get().toString()).base(baseStr).lang(lang).parse(dest);
            } else if (getSourceFile().isPresent()) {
                try (InputStream s = Files.newInputStream(getSourceFile().get())) {
                    RDFParser.source(s).base(baseStr).lang(lang).parse(dest);
                }
            } else {
            RDFParser.source(getSourceInputStream().get()).base(baseStr).lang(lang).parse(dest);
        }
    }