import { streamUtils } from "https://deno.land/x/dtils@2.2.1/deps.ts";
const { iterateReader } = streamUtils;
Turns a Reader, r
, into an async iterator.
import { iterateReader } from "https://deno.land/std@0.224.0/streams/iterate_reader.ts";
let f = await Deno.open("/etc/passwd");
for await (const chunk of iterateReader(f)) {
console.log(chunk);
}
f.close();
Second argument can be used to tune size of a buffer. Default size of the buffer is 32kB.
import { iterateReader } from "https://deno.land/std@0.224.0/streams/iterate_reader.ts";
let f = await Deno.open("/etc/passwd");
const it = iterateReader(f, {
bufSize: 1024 * 1024
});
for await (const chunk of it) {
console.log(chunk);
}
f.close();