s3si.ts/src/jsonrpc/deno.ts

import { readLines } from "../utils.ts";
import { Transport } from "./types.ts";

export class DenoIO implements Transport {
  lines: AsyncIterableIterator<string>;
  writer: WritableStream<Uint8Array>;
  constructor({ reader, writer }: {
    reader: ReadableStream<Uint8Array>;
    writer: WritableStream<Uint8Array>;
  }) {
    this.lines = readLines(reader);
    this.writer = writer;
  }
  async recv(): Promise<string | undefined> {
    const result = await this.lines.next();

    if (!result.done) {
      return result.value;
    }

    return undefined;
  }
  async send(data: string) {
    const writer = this.writer.getWriter();
    try {
      await writer.ready;
      await writer.write(new TextEncoder().encode(data + "\n"));
    } finally {
      writer.releaseLock();
    }
  }
  async close() {
    await this.writer.close();
  }
}