Skip to content

Conversation

@jlabedo
Copy link
Contributor

@jlabedo jlabedo commented Dec 23, 2025

Why is this change proposed?

Handle projecting from multiple prooph's stream

Description of Changes

  • Implemented EventStoreMultiStreamSource as a composition over EventStoreGlobalStreamSource instances.
  • Per stream, a small page is loaded and events are interleaved globally by:
    • created_at column
    • configured stream order (tie‑breaker)
    • no ascending (final tie‑breaker)
  • Combined projection position is encoded as stream=position:g1,g2;....

The requested batch size is handled on a best-effort basis: it may be smaller or larger depending on how events are distributed across streams.

Pull Request Contribution Terms

  • I have read and agree to the contribution terms outlined in CONTRIBUTING.

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