Function writeReadableToWritable

shared/r2-storage.ts:12–33

(
    readable: ReadableStream<Uint8Array>,
    writable: WritableStream<ArrayBuffer | ArrayBufferView>,
)

};

async function writeReadableToWritable(
    readable: ReadableStream<Uint8Array>,
    writable: WritableStream<ArrayBuffer | ArrayBufferView>,
): Promise<void> {
    const reader = readable.getReader();
    const writer = writable.getWriter();

    try {
        while (true) {
            const { done, value } = await reader.read();
            if (done) break;
            await writer.write(value);
        }
        await writer.close();
    } catch (error) {
        await writer.abort(error).catch(() => undefined);
        throw error;
    } finally {
        reader.releaseLock();
        writer.releaseLock();
    }
}

export function refreshR2ObjectTtl(
    bucket: R2Bucket,