1 files changed, 4 insertions, 11 deletions

diff --git a/src/n3.c b/src/n3.c
index 9fb256af..8e599458 100644
--- a/src/n3.c
+++ b/src/n3.c
@@ -1100,9 +1100,7 @@ read_anon(SerdReader* const reader,
       return r_err(reader, SERD_ERR_BAD_SYNTAX, "`.' inside blank\n");
     }
     read_ws_star(reader);
-    if (reader->end_func) {
-      reader->end_func(reader->handle, deref(reader, *dest));
-    }
+    serd_sink_write_end(reader->sink, deref(reader, *dest));
     *ctx.flags = old_flags;
   }
   return (eat_byte_check(reader, ']') == ']') ? SERD_SUCCESS
@@ -1449,9 +1447,7 @@ read_base(SerdReader* const reader, const bool sparql, const bool token)
 
   Ref uri = 0;
   TRY(st, read_IRIREF(reader, &uri));
-  if (reader->base_func) {
-    TRY(st, reader->base_func(reader->handle, deref(reader, uri)));
-  }
+  TRY(st, serd_sink_write_base(reader->sink, deref(reader, uri)));
   pop_node(reader, uri);
 
   read_ws_star(reader);
@@ -1489,10 +1485,8 @@ read_prefixID(SerdReader* const reader, const bool sparql, const bool token)
   Ref uri = 0;
   TRY(st, read_IRIREF(reader, &uri));
 
-  if (reader->prefix_func) {
-    st = reader->prefix_func(
-      reader->handle, deref(reader, name), deref(reader, uri));
-  }
+  st = serd_sink_write_prefix(
+    reader->sink, deref(reader, name), deref(reader, uri));
 
   pop_node(reader, uri);
   pop_node(reader, name);
@@ -1500,7 +1494,6 @@ read_prefixID(SerdReader* const reader, const bool sparql, const bool token)
     read_ws_star(reader);
     st = eat_byte_check(reader, '.') ? SERD_SUCCESS : SERD_ERR_BAD_SYNTAX;
   }
-
   return st;
 }