You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2026/02/26 09:20:08 UTC
(jena) 02/04: create method for StreamRDF2
This is an automated email from the ASF dual-hosted git repository.
andy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/jena.git
commit c4e11858ca4d9aba3ba7349e0523fbeb9944cf3d
Author: Andy Seaborne <an...@apache.org>
AuthorDate: Wed Feb 25 16:56:17 2026 +0000
create method for StreamRDF2
---
.../src/main/java/org/apache/jena/riot/system/StreamRDF2.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git a/jena-arq/src/main/java/org/apache/jena/riot/system/StreamRDF2.java b/jena-arq/src/main/java/org/apache/jena/riot/system/StreamRDF2.java
index a0f4c7f45e..f5313743fa 100644
--- a/jena-arq/src/main/java/org/apache/jena/riot/system/StreamRDF2.java
+++ b/jena-arq/src/main/java/org/apache/jena/riot/system/StreamRDF2.java
@@ -29,7 +29,15 @@ public class StreamRDF2 implements StreamRDF {
protected final StreamRDF sink1;
protected final StreamRDF sink2;
- public StreamRDF2(StreamRDF sink1, StreamRDF sink2) {
+ public static StreamRDF create(StreamRDF sink1, StreamRDF sink2) {
+ if ( sink1 == null )
+ return sink2;
+ if ( sink2 == null )
+ return sink1;
+ return new StreamRDF2(sink1, sink2);
+ }
+
+ private StreamRDF2(StreamRDF sink1, StreamRDF sink2) {
this.sink1 = sink1;
this.sink2 = sink2;
}
@@ -75,5 +83,4 @@ public class StreamRDF2 implements StreamRDF {
sink1.finish();
sink2.finish();
}
-
}