summaryrefslogtreecommitdiff
path: root/std/io/readers.ts
diff options
context:
space:
mode:
authorRyan Dahl <ry@tinyclouds.org>2019-10-10 05:31:23 -0400
committerGitHub <noreply@github.com>2019-10-10 05:31:23 -0400
commite7562eed8c816cd0d97aab6b818d7c8453dbaa2b (patch)
treec5a9f536e79d2c8d2d02897511a9138acaf35394 /std/io/readers.ts
parent3882c9d19a641e0c919f1350d87c6d7ee280cf78 (diff)
parent93f7f00c956c14620ef031626f124b57397ca867 (diff)
Merge deno_std in main repo (#3091)
The history of deno_std is persevered but rewritten to update links to issues and PRs Fixes denoland/deno_std#603
Diffstat (limited to 'std/io/readers.ts')
m---------std0
-rw-r--r--std/io/readers.ts42
2 files changed, 42 insertions, 0 deletions
diff --git a/std b/std
deleted file mode 160000
-Subproject 43aafbf33285753e7b42230f0eb7969b300f71c
diff --git a/std/io/readers.ts b/std/io/readers.ts
new file mode 100644
index 000000000..0208de413
--- /dev/null
+++ b/std/io/readers.ts
@@ -0,0 +1,42 @@
+// Copyright 2018-2019 the Deno authors. All rights reserved. MIT license.
+type Reader = Deno.Reader;
+import { encode } from "../strings/mod.ts";
+
+/** Reader utility for strings */
+export class StringReader implements Reader {
+ private offs = 0;
+ private buf = new Uint8Array(encode(this.s));
+
+ constructor(private readonly s: string) {}
+
+ async read(p: Uint8Array): Promise<number | Deno.EOF> {
+ const n = Math.min(p.byteLength, this.buf.byteLength - this.offs);
+ p.set(this.buf.slice(this.offs, this.offs + n));
+ this.offs += n;
+ if (n === 0) {
+ return Deno.EOF;
+ }
+ return n;
+ }
+}
+
+/** Reader utility for combining multiple readers */
+export class MultiReader implements Reader {
+ private readonly readers: Reader[];
+ private currentIndex = 0;
+
+ constructor(...readers: Reader[]) {
+ this.readers = readers;
+ }
+
+ async read(p: Uint8Array): Promise<number | Deno.EOF> {
+ const r = this.readers[this.currentIndex];
+ if (!r) return Deno.EOF;
+ const result = await r.read(p);
+ if (result === Deno.EOF) {
+ this.currentIndex++;
+ return 0;
+ }
+ return result;
+ }
+}