Skip to main content
Module

x/msgpack_rpc/deps.ts>streams.iterateReader

🦕 Deno module to support msgpack-rpc
Latest
function streams.iterateReader
import { streams } from "https://deno.land/x/msgpack_rpc@v4.0.0/deps.ts";
const { iterateReader } = streams;

Turns a Reader, r, into an async iterator.

import { iterateReader } from "https://deno.land/std@0.224.0/streams/conversion.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/conversion.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();

Parameters

optional
options: { bufSize?: number; }

Returns

AsyncIterableIterator<Uint8Array>