12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
// Copyright 2018-2021 the oak authors. All rights reserved. MIT license.
import { assert, assertEquals } from "./test_deps.ts";
import { AsyncIterableReader } from "./async_iterable_reader.ts";
const { test } = Deno;
const encoder = new TextEncoder();const decoder = new TextDecoder();
test({  name: "AsyncIterableReader - basic",  async fn() {    const rs = new ReadableStream<string>({      start(controller) {        controller.enqueue("hello deno");        controller.close();      },    });
    const air = new AsyncIterableReader(rs, (value) => encoder.encode(value));
    let buf = new Uint8Array(1000);    let bytesRead = await air.read(buf);    assertEquals(bytesRead, 10);    assert(decoder.decode(buf).startsWith("hello deno"));
    buf = new Uint8Array(1000);    bytesRead = await air.read(buf);    assertEquals(bytesRead, null);  },});
test({  name: "AsyncIterableReader - multiple chunks",  async fn() {    const rs = new ReadableStream<string>({      start(controller) {        controller.enqueue("hello");        controller.enqueue("deno");        controller.close();      },    });
    const air = new AsyncIterableReader(rs, (value) => encoder.encode(value));
    let buf = new Uint8Array(1000);    let bytesRead = await air.read(buf);    assertEquals(bytesRead, 5);    assert(decoder.decode(buf).startsWith("hello"));
    buf = new Uint8Array(1000);    bytesRead = await air.read(buf);    assertEquals(bytesRead, 4);    assert(decoder.decode(buf).startsWith("deno"));
    buf = new Uint8Array(1000);    bytesRead = await air.read(buf);    assertEquals(bytesRead, null);  },});
test({  name: "AsyncIterableReader - overflow",  async fn() {    const rs = new ReadableStream<string>({      start(controller) {        controller.enqueue("hello deno");        controller.close();      },    });
    const air = new AsyncIterableReader(rs, (value) => encoder.encode(value));
    let buf = new Uint8Array(5);    let bytesRead = await air.read(buf);    assertEquals(bytesRead, 5);    assert(decoder.decode(buf).startsWith("hello"));
    buf = new Uint8Array(5);    bytesRead = await air.read(buf);    assertEquals(bytesRead, 5);    assert(decoder.decode(buf).startsWith(" deno"));
    buf = new Uint8Array(5);    bytesRead = await air.read(buf);    assertEquals(bytesRead, null);  },});