std/streams
2022-02-02 23:21:39 +09:00
..
conversion_test.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
conversion.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
delimiter_test.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
delimiter.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
merge_test.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
merge.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
mod.ts chore: update copyright header (#1871) 2022-02-02 23:21:39 +09:00
README.md feat: streams utilities (#1141) 2021-10-12 11:51:48 +02:00

std/streams

Conversion

readerFromStreamReader

Creates a Reader from a ReadableStreamDefaultReader.

import {
  copy,
  readerFromStreamReader,
} from "https://deno.land/std@$STD_VERSION/streams/mod.ts";
const res = await fetch("https://deno.land");
const file = await Deno.open("./deno.land.html", { create: true, write: true });

const reader = readerFromStreamReader(res.body!.getReader());
await copy(reader, file);
file.close();

writerFromStreamWriter

Creates a Writer from a WritableStreamDefaultWriter.

import {
  copy,
  writerFromStreamWriter,
} from "https://deno.land/std@$STD_VERSION/streams/mod.ts";
const file = await Deno.open("./deno.land.html", { read: true });

const writableStream = new WritableStream({
  write(chunk): void {
    console.log(chunk);
  },
});
const writer = writerFromStreamWriter(writableStream.getWriter());
await copy(file, writer);
file.close();