12345678910111213141516171819202122232425262728293031323334353637383940
import {  assertEquals,  assertInstanceOf,} from "https://deno.land/std@0.186.0/testing/asserts.ts";import { concat } from "https://deno.land/std@0.186.0/bytes/mod.ts";import { WorkerWriter } from "./mod.ts";import { MockWorker } from "./test_util.ts";
Deno.test(  "WorkerWriter invokes internal worker.postMessage when data is written by 'write' method",  async () => {    const worker = new MockWorker();    const chunks: Uint8Array[] = [];    worker.addEventListener("message", (ev) => {      assertInstanceOf(ev, MessageEvent<Uint8Array>);      chunks.push(ev.data);    });    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]));    const content = concat(...chunks);    assertEquals(content, new Uint8Array([0, 1, 2, 3, 4, 5, 6, 7, 8, 9]));  },);
Deno.test(  "WorkerWriter send 'null' when 'close' method is called",  () => {    const worker = new MockWorker();    const chunks: null[] = [];    worker.addEventListener("message", (ev) => {      assertInstanceOf(ev, MessageEvent<null>);      chunks.push(ev.data);    });    const writer = new WorkerWriter(worker);    writer.close();    assertEquals(chunks, [null]);  },);