1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
// Copyright 2019-2020 Yusuke Sakurai. All rights reserved. MIT license.import { promiseInterrupter } from "./_util.ts";import { BodyReader } from "./server.ts";
const nullBuffer = new Uint8Array(1024);
export function closableBodyReader(r: Deno.Reader): BodyReader {  return {    read: r.read,    async close() {      await readUntilEof(r);    },  };}
export async function readUntilEof(reader: Deno.Reader): Promise<number> {  let total = 0;  while (true) {    const result = await reader.read(nullBuffer);    if (result == null) {      break;    }    total += result;  }  return total;}
const kDefaultReadTimeout = 10000; // 10sec
export function timeoutReader(  r: Deno.Reader,  opts?: {    timeout?: number;    cancel?: Promise<void>;  },): Deno.Reader {  if (!opts) return r;  if (opts.timeout === undefined) {    opts.timeout = kDefaultReadTimeout;  }  let timeoutOrCancel = promiseInterrupter(opts);  return {    async read(p: Uint8Array): Promise<number | null> {      return await timeoutOrCancel(r.read(p));    },  };}
export function streamReader(stream: ReadableStream<Uint8Array>): Deno.Reader {  const reader = stream.getReader();  const chunks: Uint8Array[] = [];
  const read = async (p: Uint8Array): Promise<number | null> => {    const set = (bytes: Uint8Array): number => {      p.set(bytes);      return bytes.byteLength;    };    const chunk = chunks.shift();    if (chunk) {      if (chunk.byteLength <= p.byteLength) {        return set(chunk);      } else {        const ret = set(chunk.subarray(0, p.byteLength));        chunks.unshift(chunk.subarray(p.byteLength));        return ret;      }    }    const { value, done } = await reader.read();    if (done || !value) {      return null;    }    if (value.byteLength <= p.byteLength) {      return set(value);    } else {      const ret = set(value.subarray(0, p.byteLength));      chunks.push(value.subarray(p.byteLength));      return ret;    }  };  return { read };}
export function noopReader(): Deno.Reader {  return {    async read() {      return null;    },  };}