Function streamFetch

native.ts:52–69

(url: string, method: string, headers: Record<string, string>, parts: Uint8Array[], contentType?: string)

}

function streamFetch(url: string, method: string, headers: Record<string, string>, parts: Uint8Array[], contentType?: string): Promise<Response> {
    const total = parts.reduce((sum, part) => sum + part.length, 0);
    const finalHeaders: Record<string, string> = { ...headers, "Content-Length": String(total) };
    if (contentType) finalHeaders["Content-Type"] = contentType;

    const controller = new AbortController();
    activeUploadController = controller;

    return fetch(url, {
        method,
        headers: finalHeaders,
        body: progressStream(parts),
        duplex: "half",
        signal: controller.signal
    } as RequestInit & { duplex: "half"; }).finally(() => {
        if (activeUploadController === controller) activeUploadController = null;
    });
}

function multipartFetch(url: string, fields: Record<string, string>, fileFieldName: string, fileBuffer: ArrayBuffer, filename: string, headers: Record<string, string> = {}): Promise<Response> {
    const boundary = `----BigFileUpload${Date.now().toString(16)}${Math.random().toString(16).slice(2)}`;