Formed in 2009, the Archive Team (not to be confused with the archive.org Archive-It Team) is a rogue archivist collective dedicated to saving copies of rapidly dying or deleted websites for the sake of history and digital heritage. The group is 100% composed of volunteers and interested parties, and has expanded into a large amount of related projects for saving online and digital history.
Join GitHub today
GitHub is home to over 50 million developers working together to host and review code, manage projects, and build software together.
Sign upGitHub is where the world builds software
Millions of developers and companies build, ship, and maintain their software on GitHub — the largest and most advanced development platform in the world.
PoC: Event streaming #464
PoC: Event streaming #464
Conversation
Codecov Report
@@ Coverage Diff @@
## develop #464 +/- ##
===========================================
+ Coverage 75.23% 75.34% +0.11%
===========================================
Files 258 259 +1
Lines 6500 6669 +169
Branches 539 548 +9
===========================================
+ Hits 4890 5025 +135
- Misses 1381 1402 +21
- Partials 229 242 +13
Continue to review full report at Codecov.
|
|
is there no way to implement this for the Eventstore.Eventstore? We expect to have some aggravates with huge amount of events and are planning to use eventstore. Do you expect that these changes will outperforme eventstore? |
|
Hi @wgtmpeters I just haven't done the implementation for EventStore yet, but I'll look into it. It should be relatively easy as the current implementation is already loading events in batches, but is currently putting them into a list before returning. I haven't looked into how bulk inserting would work for EventStore. But I hope these changes, along with event archiving, will make it easier to manage huge event stores and aggregates. |
Relevant for
Current implementation uses the
System.Interactive.AsyncNuGet package, but C# 8 might introduceIAsyncEnumerableas part of the language.To do
System.Interactive.Async