Method constructor

http/unstable_formdata_encoder_stream.ts:88–137

* Constructs a new instance. * * @param readable The readable stream of form data inputs.

(readable: ReadableStream<FormDataInput>)

   * @param readable The readable stream of form data inputs.
   */
  constructor(readable: ReadableStream<FormDataInput>) {
    const boundary = "--deno-std-" +
      encodeBase64(crypto.getRandomValues(new Uint8Array(30))) +
      "\r\n";
    this.#encoder
      .encodeInto(boundary, this.#boundary = new Uint8Array(boundary.length));
    this.#contentType = 'multipart/form-data; boundary="' +
      boundary.slice(2, -2) + '"';

    const gen = this.#handle(readable);
    this.#readable = new ReadableStream({
      type: "bytes",
      autoAllocateChunkSize: 1024,
      async start() {
        await gen.next();
      },
      async pull(controller) {
        const length = controller.byobRequest!.view!.byteLength;
        const buffer = new Uint8Array(
          controller.byobRequest!.view!.buffer,
          controller.byobRequest!.view!.byteOffset,
          length,
        );

        try {
          const { done, value } = await gen.next(buffer);
          if (done) {
            controller.close();
            return controller.byobRequest!.respond(0);
          }

          // deno-lint-ignore no-explicit-any
          if ((buffer.buffer as any).detached) {
            controller.byobRequest!.respondWithNewView(value);
          } else if (buffer.buffer === value.buffer) {
            controller.byobRequest!.respond(value.length);
          } else {
            buffer.set(value.subarray(0, length));
            controller.byobRequest!.respond(length);
            controller.enqueue(value.subarray(length));
          }
        } catch (error) {
          controller.error(error);
        }
      },
      async cancel(reason) {
        await gen.throw(reason).catch(() => undefined);
      },
    });
  }

  async *#handle(
    readable: ReadableStream<FormDataInput>,