fix: no need to make resulting function async

src/index.ts

@@ -14,9 +14,7 @@ type ValidateArguments = {
     validationIsFatal?: boolean;
 };
 
-export async function validate(
-    args: ValidateArguments,
-): Promise<() => Promise<void>> {
+export async function validate(args: ValidateArguments): Promise<() => void> {
     const { shaclPath, incoming, outgoing, report, validationIsFatal } = args;
 
     // Initialize the shared serializer.
@@ -42,7 +40,7 @@ export async function validate(
     // @ts-expect-error Factory is valid.
     const validator = new Validator(shapes, { factory: rdf });
 
-    return async () => {
+    return () => {
         // Anything that passes through this processor and identifies with a
         // specific shape should match the SHACL definition.
         incoming.on("data", async (data) => {

tests/error.test.ts

@@ -12,13 +12,14 @@ describe("errors", () => {
     test("invalid shacl file path", async () => {
         expect.assertions(1);
 
-        const func = validate({
-            shaclPath: "/tmp/shacl-doesnt-exist.ttl",
-            incoming: new SimpleStream<string>(),
-            outgoing: new SimpleStream<string>(),
-        });
-
-        expect(func).rejects.toThrow(ShaclError.fileSystemError());
+        const func = () =>
+            validate({
+                shaclPath: "/tmp/shacl-doesnt-exist.ttl",
+                incoming: new SimpleStream<string>(),
+                outgoing: new SimpleStream<string>(),
+            });
+
+        expect(func()).rejects.toThrow(ShaclError.fileSystemError());
     });
 
     test("invalid shacl rdf format", async () => {
@@ -30,7 +31,7 @@ describe("errors", () => {
             outgoing: new SimpleStream<string>(),
         });
 
-        expect(func).rejects.toThrow(ShaclError.invalidRdfFormat());
+        expect(func).rejects.toThrowError(ShaclError.invalidRdfFormat());
     });
 
     test("invalid input data", async () => {
@@ -44,7 +45,7 @@ describe("errors", () => {
             incoming,
             outgoing,
         });
-        await func();
+        func();
 
         expect(
             incoming.push("This is not a valid Turtle file!"),
@@ -65,7 +66,7 @@ describe("errors", () => {
             outgoing: new SimpleStream<string>(),
             validationIsFatal: true,
         });
-        await func();
+        func();
 
         expect(incoming.push(invalidRdfData)).rejects.toThrow(
             ShaclError.validationFailed(),

tests/index.test.ts

@@ -61,7 +61,7 @@ beforeEach(async () => {
         outgoing,
         report,
     });
-    await func();
+    func();
 });
 
 describe("shacl", () => {