Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Create StreamableMessageSource that joins several streams into one #1069

Open
abuijze opened this issue Apr 25, 2019 · 0 comments

Comments

Projects
None yet
3 participants
@abuijze
Copy link
Member

commented Apr 25, 2019

In certain cases, it is desirable to read events from multiple sources into a single processor. For example, when a projection is created from different contexts.

To support this range of features, there should be a StreamableMessageSource implementation that combines multiple sources into a single one. To ensure Tokens are maintained correctly, each substream must be identified with an identifier. The Token returned by the merged stream will contain a mapping of each individual Token of each substream.

When reading messages, the combining stream should evaluable the substream's messages to decide which one to return first. The default strategy is to return the message with the lowest timestamp.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.