Method #handle

http/unstable_formdata_encoder_stream.ts:139–196

(
    readable: ReadableStream<FormDataInput>,
  )

  }

  async *#handle(
    readable: ReadableStream<FormDataInput>,
  ): AsyncGenerator<Uint8Array, void, Uint8Array> {
    const fixed = [
      this.#encoder.encode('Content-Disposition: form-data; name="'),
      this.#encoder.encode('"; filename="'),
      this.#encoder.encode('"\r\nContent-Type: '),
      this.#encoder.encode('text/plain; charset="UTF-8"\r\n\r\n'),
      this.#encoder.encode("application/octet-stream\r\n\r\n"),
      this.#encoder.encode("\r\n\r\n"),
      this.#encoder.encode("\r\n"),
    ];
    let buffer = yield new Uint8Array();
    for await (const input of readable) {
      buffer = yield this.#setBuffer(buffer, this.#boundary);

      buffer = yield this.#setBuffer(buffer, fixed[0]!);
      buffer = yield this.#setString(buffer, input.name);
      if (input.filename != undefined || typeof input.value !== "string") {
        buffer = yield this.#setBuffer(buffer, fixed[1]!);
        buffer = yield this.#setString(buffer, input.filename ?? "blob");
      }
      buffer = yield this.#setBuffer(buffer, fixed[2]!);

      if (input.contentType != undefined) {
        buffer = yield this.#setString(buffer, input.contentType);
        buffer = yield this.#setBuffer(buffer, fixed[5]!);
      } else if (typeof input.value === "string") {
        buffer = yield this.#setBuffer(buffer, fixed[3]!);
      } else if (input.value instanceof Blob && input.value.type.length) {
        buffer = yield this.#setString(buffer, input.value.type);
        buffer = yield this.#setBuffer(buffer, fixed[5]!);
      } else {
        buffer = yield this.#setBuffer(buffer, fixed[4]!);
      }

      if (typeof input.value === "string") {
        buffer = yield this.#setString(buffer, input.value);
      } else {
        if (input.value instanceof Blob) input.value = input.value.stream();
        const reader = toByteStream(input.value).getReader({ mode: "byob" });
        try {
          while (true) {
            const { done, value } = await reader
              .read(buffer, { min: buffer.length });
            buffer = yield value!;
            if (done) break;
          }
        } catch (reason) {
          await reader.cancel(reason);
          throw reason;
        }
      }
      buffer = yield this.#setBuffer(buffer, fixed[6]!);
    }
    this.#boundary.set([45, 45], this.#boundary.length - 2);
    yield this.#setBuffer(buffer, this.#boundary);
  }