Example: Bound upload buffering with streamed chunks

[bthavanish]

Purpose

Example source-level improvement for #79. This PR is intentionally a draft and unmerged.

What changed

• Adds forEachUploadChunk() to stream temporary upload files using a bounded highWaterMark.
• Awaits each consumer callback so a slow daemon naturally applies backpressure.
• Ensures the stream is destroyed on completion/error.

Follow-up before merge

Replace the upload handler's memoryStorage() path with disk-backed multipart storage and use this helper for the large-file branch. Add resource-cleanup and concurrent-upload tests.

References #79.

[coderabbitai]

Important

Draft PR not reviewed

Draft PRs are not automatically reviewed by default.

• Trigger a manual review

To automatically review draft PRs, update your CodeRabbit configuration:

reviews:
  auto_review:
    drafts: true

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands.}