public AggregatorFor method #3598
Open
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…ionality for custom construction of aggregates.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Made AggregatorFor public in order to be able to fetch generated live aggregations of projections from codegen.
I made this in relation to a person project of mine where I would like to fetch data for multiple streams live at the same time.
The flow I wish to achieve is for live aggregation of streams on top of snapshots with multiple streams.
This is to enable being able perform a predicate on the snapshot with async lifecycle.
Afterwards fetching the rest of these streams live to ensure 100% up to date view.
Then applying the predicate once again to ensure no false results in the query.
This ofcause has a flaw of not fetching all streams in the inital query, thereby not get the entire result. But that is acceptable in the scenario I have.