Use Uint8Array as-is to improve performance

Close #3

Note that this package supports Deno v1.10 or over from this commit.

https://deno.com/blog/v1.10#worker.postmessage-supports-structured-clone-algorithm

README.md

@@ -7,8 +7,13 @@
 [Deno][deno] module to translate Worker's system of messages into
 [Reader][reader] and [Writer][writer].
 
-Note that `WorkerReader` and `WorkerWriter` access `Deno` namespace thus
-[Using Deno in worker](https://deno.land/manual@v1.7.5/runtime/workers#using-deno-in-worker)
+Note that this package requires
+[`Worker.postMessage` supports structured clone
+algorithm](https://deno.com/blog/v1.10#worker.postmessage-supports-structured-clone-algorithm)
+introduced in Deno v1.10.
+
+Note that this package accesses `Deno` namespace thus
+[Using Deno in worker](https://deno.land/manual@v1.11.0/runtime/workers#using-deno-in-worker)
 must be enabled.
 
 [deno]: https://deno.land/

reader.ts

@@ -16,7 +16,7 @@ export class WorkerReader implements Deno.Reader, Deno.Closer {
     this.#worker = worker;
     this.#worker.onmessage = (e) => {
       if (this.#queue && !this.#closed) {
-        this.#queue.put_nowait(new Uint8Array(e.data));
+        this.#queue.put_nowait(e.data);
       }
     };
   }

reader_test.ts

@@ -12,13 +12,13 @@ Deno.test(
     worker.onmessage?.call(
       worker,
       new MessageEvent("worker", {
-        data: [0, 1, 2, 3, 4],
+        data: new Uint8Array([0, 1, 2, 3, 4]),
       }),
     );
     worker.onmessage?.call(
       worker,
       new MessageEvent("worker", {
-        data: [5, 6, 7, 8, 9],
+        data: new Uint8Array([5, 6, 7, 8, 9]),
       }),
     );
     let p: Uint8Array;
@@ -45,14 +45,14 @@ Deno.test(
     worker.onmessage?.call(
       worker,
       new MessageEvent("worker", {
-        data: [0, 1, 2, 3, 4],
+        data: new Uint8Array([0, 1, 2, 3, 4]),
       }),
     );
     reader.close();
     worker.onmessage?.call(
       worker,
       new MessageEvent("worker", {
-        data: [5, 6, 7, 8, 9],
+        data: new Uint8Array([5, 6, 7, 8, 9]),
       }),
     );
     let p: Uint8Array;
@@ -78,14 +78,14 @@ Deno.test(
     worker.onmessage?.call(
       worker,
       new MessageEvent("worker", {
-        data: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9],
+        data: new Uint8Array([0, 1, 2, 3, 4, 5, 6, 7, 8, 9]),
       }),
     );
     reader.close();
     worker.onmessage?.call(
       worker,
       new MessageEvent("worker", {
-        data: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9],
+        data: new Uint8Array([0, 1, 2, 3, 4, 5, 6, 7, 8, 9]),
       }),
     );
     let n: number | null;

types.ts

@@ -1,4 +1,4 @@
-type Payload = number[];
+type Payload = Uint8Array;
 
 export type WorkerForWorkerReader = {
   onmessage?: (message: MessageEvent<Payload>) => void;

writer.ts

@@ -16,10 +16,7 @@ export class WorkerWriter implements Deno.Writer {
    * https://github.com/lambdalisue/deno-workerio/issues/5
    */
   write(p: Uint8Array): Promise<number> {
-    // XXX
-    // Send 'p' as-is once the issue below has resolved.
-    // https://github.com/denoland/deno/issues/3557
-    this.#worker.postMessage(Array.from(p));
+    this.#worker.postMessage(p);
     return Promise.resolve(p.length);
   }
 }

writer_test.ts

@@ -4,7 +4,7 @@ import { WorkerForWorkerWriter, WorkerWriter } from "./mod.ts";
 Deno.test(
   "WorkerWriter invokes internal worker.postMessage when data is written by 'write' method",
   async () => {
-    const posted: number[][] = [];
+    const posted: Uint8Array[] = [];
     const worker: WorkerForWorkerWriter = {
       postMessage(message) {
         posted.push(message);
@@ -13,7 +13,7 @@ Deno.test(
     const writer = new WorkerWriter(worker);
     await writer.write(new Uint8Array([0, 1, 2, 3, 4]));
     await writer.write(new Uint8Array([5, 6, 7, 8, 9]));
-    assertEquals(posted[0], [0, 1, 2, 3, 4]);
-    assertEquals(posted[1], [5, 6, 7, 8, 9]);
+    assertEquals(posted[0], new Uint8Array([0, 1, 2, 3, 4]));
+    assertEquals(posted[1], new Uint8Array([5, 6, 7, 8, 9]));
   },
 );