denosaurs / event Goto Github PK

import { assertEquals } from "jsr:@std/assert";

class DuplexStream<T> extends TransformStream<T, T> {}

Deno.test("Streams", async (t) => {
  const stream = new DuplexStream<string>();

  const expected = [
    "Hello there",
    "Here's some string data",
    "All done",
  ];

  await t.step("Writing", async () => {
    const w = stream.writable.getWriter();

    for await (const element of expected) {
      await w.ready;
      // Error: Promise resolution is still pending but the event loop has already resolved.
      await w.write(element);
    }

    await w.ready;
    w.releaseLock();
  });

  await t.step("Reading", async () => {
    const r = stream.readable.values();

    const actual = await Array.fromAsync(r);

    assertEquals(actual, expected);
  });
});

import { assertEquals } from "jsr:@std/assert";

Deno.test("Streams 2", async (t) => {
  const collected: string[] = [];

  const stream = new WritableStream<string>({
    write(ch) {
      collected.push(ch);
    },
  });

  const expected = [
    "Hello there",
    "Here's some string data",
    "All done",
  ];

  await t.step("Writing", async () => {
    const w = stream.getWriter();

    for await (const element of expected) {
      await w.ready;
      await w.write(element);
    }

    await w.ready;
    w.releaseLock();
  });

  await t.step("Reading", () => {
    assertEquals(collected, expected);
  });
});

import { assertEquals } from "jsr:@std/assert";

class DuplexStream<T> extends TransformStream<T, T> {}

Deno.test("Streams 3", async (t) => {
  const stream = new DuplexStream<string>();

  const expected = [
    "Hello there",
    "Here's some string data",
    "All done",
  ];

  await t.step("Writing & Reading", async () => {
    const r = ReadableStream.from(expected).pipeThrough(stream).values();

    const actual = await Array.fromAsync(r);

    assertEquals(actual, expected);
  });
});