Provide a full output stream implementation for SerdBuffer

Essentially replaces serd_buffer_sink_finish() with serd_buffer_close(), which
makes writing to a buffer consistent with writing to a file or anything else.

2 files changed, 7 insertions, 0 deletions

diff --git a/tools/serd-pipe.c b/tools/serd-pipe.c
index 25efb54f..57392c8a 100644
--- a/tools/serd-pipe.c
+++ b/tools/serd-pipe.c
@@ -83,10 +83,12 @@ run(const Options opts)
       (st = serd_read_inputs(
          app.world, opts.common, app.env, opts.n_inputs, opts.inputs, sink)) ||
       (st = serd_writer_finish(app.writer))) {
+    serd_sink_free(canon);
     serd_tool_cleanup(app);
     return st;
   }
 
+  serd_sink_free(canon);
   return serd_tool_cleanup(app);
 }
 
diff --git a/tools/serd-sort.c b/tools/serd-sort.c
index 5e71e95e..bbdfa164 100644
--- a/tools/serd-sort.c
+++ b/tools/serd-sort.c
@@ -95,6 +95,8 @@ run(const Options opts)
                                    opts.n_inputs,
                                    opts.inputs,
                                    inserter))) {
+    serd_sink_free(inserter);
+    serd_model_free(model);
     serd_tool_cleanup(app);
     return st;
   }
@@ -127,6 +129,9 @@ run(const Options opts)
     st = serd_writer_finish(app.writer);
   }
 
+  serd_sink_free(inserter);
+  serd_model_free(model);
+
   const SerdStatus cst = serd_tool_cleanup(app);
   return st ? st : cst;
 }