12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
// Ported to Deno from// Copyright 2009 The Go Authors. All rights reserved.// Use of this source code is governed by a BSD-style// license that can be found in the LICENSE file.type Reader = Deno.Reader;
/** OneByteReader returns a Reader that implements * each non-empty Read by reading one byte from r. */export class OneByteReader implements Reader {  constructor(readonly r: Reader) {}
  async read(p: Uint8Array): Promise<number | Deno.EOF> {    if (p.byteLength === 0) {      return 0;    }    if (!(p instanceof Uint8Array)) {      throw Error("expected Uint8Array");    }    return this.r.read(p.subarray(0, 1));  }}
/** HalfReader returns a Reader that implements Read * by reading half as many requested bytes from r. */export class HalfReader implements Reader {  constructor(readonly r: Reader) {}
  async read(p: Uint8Array): Promise<number | Deno.EOF> {    if (!(p instanceof Uint8Array)) {      throw Error("expected Uint8Array");    }    const half = Math.floor((p.byteLength + 1) / 2);    return this.r.read(p.subarray(0, half));  }}
export class ErrTimeout extends Error {  constructor() {    super("timeout");    this.name = "ErrTimeout";  }}
/** TimeoutReader returns ErrTimeout on the second read * with no data. Subsequent calls to read succeed. */export class TimeoutReader implements Reader {  count = 0;  constructor(readonly r: Reader) {}
  async read(p: Uint8Array): Promise<number | Deno.EOF> {    this.count++;    if (this.count === 2) {      throw new ErrTimeout();    }    return this.r.read(p);  }}