_readers_test.ts

// Copyright 2019-2020 Yusuke Sakurai. All rights reserved. MIT license.
import { streamReader } from "./_readers.ts";
import { assertEquals } from "./vendor/https/deno.land/std/testing/asserts.ts";
import { group } from "./_test_util.ts";
import { decode, encode } from "./_util.ts";
import { Buffer } from "./vendor/https/deno.land/std/io/buffer.ts";

group("streamReader", ({ test }) => {
  test("basic", async () => {
    const stream = new ReadableStream<Uint8Array>({
      start(ctrl) {
        ctrl.enqueue(encode("Go "));
        ctrl.enqueue(encode("To "));
        ctrl.enqueue(encode("-> [deno.land]"));
        ctrl.close();
      },
    });
    const sr = streamReader(stream);
    const buf = new Uint8Array(3);
    const dest = new Buffer();
    let result: null | number = 0;
    while ((result = await sr.read(buf)) !== null) {
      await dest.write(buf.subarray(0, result));
    }
    assertEquals(decode(dest.bytes()), "Go To -> [deno.land]");
  });
});