Skip to content

fix(streams): end iterators after closed shard exhaustion - #1

Merged
forhappy merged 1 commit into
mainfrom
codex/stream-completion
Sep 28, 2026
Merged

forhappy merged 1 commit into
mainfrom
codex/stream-completion

Conversation

@forhappy

@forhappy forhappy commented Sep 28, 2026 •

Copy link
Copy Markdown

Summary

Keep the closed-shard Streams continuation change on a crabbuild-owned branch while upstream PR #372 is reviewed. This lets BeyondDB pin an immutable crabbuild fork commit without waiting for an official release.

  • Add StreamContinuation::More and End to the shared storage contract.
  • Return no next iterator after an exhausted closed shard, preserving records on the final page.
  • Update SQLite, PostgreSQL, and MongoDB implementations together, with one-record lookahead and the 1,000-record page limit.

Proof

This branch and upstream PR ExtendDB#372 point at the same commit, 7eaa89b437feed0af0f05883d3f1493f86c6fc6d. SQLite and engine tests, cross-backend compile checks, strict Clippy, and format checks passed when the commit was authored. BeyondDB's signed process smoke exercises the contract through the DynamoDB SDK and AWS CLI across a hard restart.

PostgreSQL and MongoDB runtime integration tests still need their database environments.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant