Don't implement Writer#write_statement, but consolidate internal logic in #write_quad. This allows Duplicate BNodes to be de-dupped.

Author: gkellogg

lib/json/ld/writer.rb

@@ -141,32 +141,15 @@ def initialize(output = $stdout, options = {}, &block)
       end
     end
 
-    ##
-    # Adds a statement to be serialized
-    # @param  [RDF::Statement] statement
-    # @return [void]
-    def write_statement(statement)
-      if statement.incomplete?
-        log_error "Statement #{statement.inspect} is incomplete"
-      elsif validate? && statement.invalid?
-        log_error "Statement #{statement.inspect} is invalid"
-      elsif @options[:stream]
-        stream_statement(statement)
-      else
-        @repo.insert(statement)
-      end
-    end
-
     ##
     # Addes a triple to be serialized
     # @param  [RDF::Resource] subject
     # @param  [RDF::URI]      predicate
     # @param  [RDF::Value]    object
     # @return [void]
-    # @raise  [NotImplementedError] unless implemented in subclass
     # @abstract
     def write_triple(subject, predicate, object)
-      write_statement(Statement.new(subject, predicate, object))
+      write_quad(subject, predicate, object, nil)
     end
 
     ##
@@ -177,7 +160,12 @@ def write_triple(subject, predicate, object)
     # @param  [RDF::Term]     object
     # @return [void]
     def write_quad(subject, predicate, object, graph_name)
-      write_statement(Statement.new(subject, predicate, object, graph_name: graph_name))
+      statement = RDF::Statement.new(subject, predicate, object, graph_name: graph_name)
+      if @options[:stream]
+        stream_statement(statement)
+      else
+        @repo.insert(statement)
+      end
     end
 
     ##