cli/js/web/streams/readable-stream-byob-request.ts


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

// Forked from https://github.com/stardazed/sd-streams/tree/8928cf04b035fd02fb1340b7eb541c76be37e546
// Copyright (c) 2018-Present by Arthur Langereis - @zenmumbler MIT

import * as rs from "./readable-internals.ts";

export class ReadableStreamBYOBRequest {
  [rs.associatedReadableByteStreamController_]:
    | rs.SDReadableByteStreamController
    | undefined;
  [rs.view_]: ArrayBufferView | undefined;

  constructor() {
    throw new TypeError();
  }

  get view(): ArrayBufferView {
    if (!rs.isReadableStreamBYOBRequest(this)) {
      throw new TypeError();
    }
    return this[rs.view_]!;
  }

  respond(bytesWritten: number): void {
    if (!rs.isReadableStreamBYOBRequest(this)) {
      throw new TypeError();
    }
    if (this[rs.associatedReadableByteStreamController_] === undefined) {
      throw new TypeError();
    }
    // If! IsDetachedBuffer(this.[[view]].[[ViewedArrayBuffer]]) is true, throw a TypeError exception.
    return rs.readableByteStreamControllerRespond(
      this[rs.associatedReadableByteStreamController_]!,
      bytesWritten
    );
  }

  respondWithNewView(view: ArrayBufferView): void {
    if (!rs.isReadableStreamBYOBRequest(this)) {
      throw new TypeError();
    }
    if (this[rs.associatedReadableByteStreamController_] === undefined) {
      throw new TypeError();
    }
    if (!ArrayBuffer.isView(view)) {
      throw new TypeError("view parameter must be a TypedArray");
    }
    // If! IsDetachedBuffer(view.[[ViewedArrayBuffer]]) is true, throw a TypeError exception.
    return rs.readableByteStreamControllerRespondWithNewView(
      this[rs.associatedReadableByteStreamController_]!,
      view
    );
  }
}