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
// Copyright 2019-2020 Yusuke Sakurai. All rights reserved. MIT license.import { Deferred, deferred } from "./vendor/https/deno.land/std/async/mod.ts";import { TimeoutError } from "./error.ts";
export function pathResolver(meta: ImportMeta): (p: string) => string {  return (p) => new URL(p, meta.url).pathname;}
export interface PromiseWaitQueue<T, P> {  enqueue(t: T): Promise<P>;}
export function promiseWaitQueue<T, P>(  creator: (t: T) => Promise<P>,): PromiseWaitQueue<T, P> {  const queue: {    d: Deferred<P>;    t: T;  }[] = [];  function enqueue(t: T): Promise<P> {    const d = deferred<P>();    queue.push({ d, t });    if (queue.length === 1) {      dequeue();    }    return d;  }  function dequeue() {    const [e] = queue;    if (!e) return;    creator(e.t)      .then(e.d.resolve)      .catch(e.d.reject)      .finally(() => {        queue.shift();        dequeue();      });  }  return { enqueue };}
/** returns curried promise factory that  */export function promiseInterrupter({  timeout = -1,  cancel,}: {  timeout?: number;  cancel?: Promise<void>;}): <T>(p: Promise<T>) => Promise<T> {  timeout = Number.isInteger(timeout) ? timeout : -1;  return <T>(p: Promise<T>) =>    new Promise<T>((resolve, reject) => {      if (timeout < 0) {        p.then(resolve).catch(reject);        if (cancel) {          cancel.then(reject).catch(reject);        }      } else {        const i = setTimeout(() => {          reject(new TimeoutError());        }, timeout);        const clear = () => clearTimeout(i);        p.then(resolve)          .catch(reject)          .finally(clear);        if (cancel) {          cancel            .then(reject)            .catch(reject)            .finally(clear);        }      }    });}
const decoder = new TextDecoder();const encoder = new TextEncoder();
export function decode(bin?: BufferSource): string {  return decoder.decode(bin);}
export function encode(s?: string): Uint8Array {  return encoder.encode(s);}