👍 Use Streams API instead

.github/workflows/test.yml

@@ -98,3 +98,9 @@ jobs:
           DENOPS_TEST_VIM_EXECUTABLE: ${{ steps.vim.outputs.executable_path }}
           DENOPS_TEST_NVIM_EXECUTABLE: ${{ steps.nvim.outputs.executable_path }}
         working-directory: ./repo
+      - run: |
+          deno coverage --unstable .coverage --lcov > coverage.lcov
+        working-directory: ./repo
+      - uses: codecov/codecov-action@v1
+        with:
+          file: ./repo/coverage.lcov

.gitignore

@@ -0,0 +1,2 @@
+deno.lock
+.coverage

README.md

@@ -3,6 +3,7 @@
 [![Test](https://github.com/vim-denops/deno-denops-test/actions/workflows/test.yml/badge.svg)](https://github.com/vim-denops/deno-denops-test/actions/workflows/test.yml)
 [![deno doc](https://doc.deno.land/badge.svg)](https://doc.deno.land/https/deno.land/x/denops_test/mod.ts)
 [![deno land](http://img.shields.io/badge/available%20on-deno.land/x/denops__test-lightgrey.svg?logo=deno)](https://deno.land/x/denops_test)
+[![codecov](https://codecov.io/github/vim-denops/deno-denops-test/branch/main/graph/badge.svg?token=X9O5XB4O1S)](https://codecov.io/github/vim-denops/deno-denops-test)
 
 [Deno][deno] module for testing [denops.vim][denops.vim]. This module is assumed
 to be used in unittests of denops plugin.

deno.jsonc

@@ -1,8 +1,9 @@
 {
   "lock": false,
   "tasks": {
-    "test": "deno test --no-lock --unstable -A --doc --parallel --shuffle",
-    "check": "deno check --no-lock --unstable $(find . -name '*.ts')",
-    "upgrade": "deno run --no-lock -A https://deno.land/x/udd/main.ts $(find . -name '*.ts')"
+    "test": "deno test --unstable -A --doc --parallel --shuffle --coverage=.coverage",
+    "check": "deno check --unstable $(find . -name '*.ts')",
+    "coverage": "deno coverage --unstable .coverage",
+    "upgrade": "deno run -A https://deno.land/x/udd/main.ts $(find . -name '*.ts')"
   }
 }

denops_test/README.md

@@ -3,6 +3,7 @@
 [![Test](https://github.com/vim-denops/deno-denops-test/actions/workflows/test.yml/badge.svg)](https://github.com/vim-denops/deno-denops-test/actions/workflows/test.yml)
 [![deno doc](https://doc.deno.land/badge.svg)](https://doc.deno.land/https/deno.land/x/denops_test/mod.ts)
 [![deno land](http://img.shields.io/badge/available%20on-deno.land/x/denops__test-lightgrey.svg?logo=deno)](https://deno.land/x/denops_test)
+[![codecov](https://codecov.io/github/vim-denops/deno-denops-test/branch/main/graph/badge.svg?token=X9O5XB4O1S)](https://codecov.io/github/vim-denops/deno-denops-test)
 
 [Deno][deno] module for testing [denops.vim][denops.vim]. This module is assumed
 to be used in unittests of denops plugin.

denops_test/conf.ts

@@ -1,4 +1,4 @@
-import * as path from "https://deno.land/std@0.186.0/path/mod.ts";
+import * as path from "https://deno.land/std@0.187.0/path/mod.ts";
 import { orElse } from "./or_else.ts";
 
 function get(name: string): string | undefined {

denops_test/plugin.ts

@@ -1,20 +1,19 @@
-import { copy } from "https://deno.land/[email protected]/streams/copy.ts";
 import {
-  WorkerReader,
-  WorkerWriter,
-} from "https://deno.land/x/workerio@v1.4.4/mod.ts#^";
+  readableStreamFromWorker,
+  writableStreamFromWorker,
+} from "https://deno.land/x/workerio@v3.1.0/mod.ts#^";
 import { orElse } from "./or_else.ts";
 
 const worker = self as unknown as Worker;
-const reader = new WorkerReader(worker);
-const writer = new WorkerWriter(worker);
+const reader = readableStreamFromWorker(worker);
+const writer = writableStreamFromWorker(worker);
 
 const addr = JSON.parse(orElse(Deno.env.get("DENOPS_TEST_ADDRESS"), () => {
   throw new Error("Environment variable `DENOPS_TEST_ADDRESS` is required");
 }));
 const conn = await Deno.connect(addr);
 
 await Promise.race([
-  copy(conn, writer).finally(() => conn.close()),
-  copy(reader, conn),
+  reader.pipeTo(conn.writable),
+  conn.readable.pipeTo(writer),
 ]);

denops_test/tester.ts

@@ -1,4 +1,4 @@
-import { sample } from "https://deno.land/std@0.186.0/collections/sample.ts";
+import { sample } from "https://deno.land/std@0.187.0/collections/sample.ts";
 import type { Denops } from "https://deno.land/x/[email protected]/mod.ts";
 import type { RunMode } from "./runner.ts";
 import { withDenops } from "./with.ts";

denops_test/tester_test.ts

@@ -2,7 +2,7 @@ import {
   assert,
   assertEquals,
   assertFalse,
-} from "https://deno.land/std@0.186.0/testing/asserts.ts";
+} from "https://deno.land/std@0.187.0/testing/asserts.ts";
 import { test } from "./tester.ts";
 
 test({

denops_test/with.ts

@@ -1,6 +1,8 @@
-import * as path from "https://deno.land/[email protected]/path/mod.ts";
-import { Session } from "https://deno.land/x/[email protected]/mod.ts#^";
-import { using } from "https://deno.land/x/[email protected]/mod.ts#^";
+import * as path from "https://deno.land/[email protected]/path/mod.ts";
+import {
+  Client,
+  Session,
+} from "https://deno.land/x/[email protected]/mod.ts#^";
 import type {
   Denops,
   Meta,
@@ -78,39 +80,37 @@ export async function withDenops(
   });
   const conn = await listener.accept();
   try {
-    await using(
-      new Session(conn, conn, {}, {
-        errorCallback(e) {
-          if (e.name === "Interrupted") {
-            return;
-          }
-          console.error("Unexpected error occurred", e);
-        },
-      }),
-      async (session) => {
-        const meta = await session.call(
-          "call",
-          "denops#_internal#meta#get",
-        ) as Meta;
-        const denops = await newDenopsImpl(meta, session, pluginName);
-        // Workaround for unexpected "leaking async ops"
-        // https://github.com/denoland/deno/issues/15425#issuecomment-1368245954
-        await new Promise((resolve) => setTimeout(resolve, 0));
-        await main(denops);
-      },
-    );
+    const session = new Session(conn.readable, conn.writable);
+    session.onInvalidMessage = (message) => {
+      console.error("Unexpected message:", message);
+    };
+    session.onMessageError = (error, message) => {
+      console.error(`Unexpected error occured for message ${message}:`, error);
+    };
+    session.start();
+    const client = new Client(session);
+    const meta = await client.call(
+      "call",
+      "denops#_internal#meta#get",
+    ) as Meta;
+    const denops = await newDenopsImpl(meta, session, client, pluginName);
+    // Workaround for unexpected "leaking async ops"
+    // https://github.com/denoland/deno/issues/15425#issuecomment-1368245954
+    await new Promise((resolve) => setTimeout(resolve, 0));
+    await main(denops);
+    await session.shutdown();
   } finally {
     proc.stdin.close();
     proc.kill();
     await proc.status;
-    conn.close();
     listener.close();
   }
 }
 
 async function newDenopsImpl(
   meta: Meta,
   session: Session,
+  client: Client,
   pluginName: string,
 ): Promise<Denops> {
   const url = path.toFileUrl(path.join(
@@ -120,5 +120,19 @@ async function newDenopsImpl(
     "impl.ts",
   ));
   const { DenopsImpl } = await import(url.href);
-  return new DenopsImpl(pluginName, meta, session);
+  return new DenopsImpl(pluginName, meta, {
+    get dispatcher() {
+      return session.dispatcher;
+    },
+    set dispatcher(dispatcher) {
+      session.dispatcher = dispatcher;
+    },
+    call(method: string, ...params: unknown[]): Promise<unknown> {
+      return client.call(method, ...params);
+    },
+    notify(method: string, ...params: unknown[]): Promise<void> {
+      client.notify(method, ...params);
+      return Promise.resolve();
+    },
+  });
 }

denops_test/with_test.ts

@@ -1,7 +1,7 @@
 import {
   assert,
   assertFalse,
-} from "https://deno.land/std@0.186.0/testing/asserts.ts";
+} from "https://deno.land/std@0.187.0/testing/asserts.ts";
 import { withDenops } from "./with.ts";
 
 Deno.test(