add stateful subscriber feature

[DavidBadura]

No description provided.

[github-actions]

Hello 👋

here is the most recent benchmark result:

SimpleSetupBench
================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.113ms (±0.00%)   | 1.144ms (±0.00%)   | -2.67%    | 35.044mb        | 35.562mb   | -1.45%      |
| benchLoad10000Events ()                | 65.352ms (±0.00%)  | 65.343ms (±0.00%)  | +0.01%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave1Event ()                     | 1.266ms (±0.00%)   | 1.203ms (±0.00%)   | +5.19%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave10000Events ()                | 240.945ms (±0.00%) | 242.544ms (±0.00%) | -0.66%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.385s (±0.00%)    | 8.484s (±0.00%)    | -1.17%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 5.307s (±0.00%)    | 5.296s (±0.00%)    | +0.20%    | 35.044mb        | 35.044mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

NoopSubscriptionEngineBench
===========================

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 82.943ms (±0.00%) | 83.711ms (±0.00%) | -0.92%    | 47.560mb        | 47.560mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

SnapshotsBench
==============

+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                   | memory                                     |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchLoad10000EventsMissingSnapshot () | 67.583ms (±0.00%) | 63.284ms (±0.00%) | +6.79%    | 35.049mb        | 35.049mb   | 0.00%       |
| benchLoad10000Events ()                | 1.320ms (±0.00%)  | 1.326ms (±0.00%)  | -0.45%    | 35.049mb        | 35.049mb   | 0.00%       |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

CommandToQueryBench
===================

+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
|                | time (kde mode)                                 | memory                                     |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
| subject        | Tag: <current>   | Tag: base        | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
| benchCreate () | 3.050ms (±0.00%) | 2.876ms (±0.00%) | +6.02%    | 4.896mb         | 4.896mb    | 0.00%       |
| benchUpdate () | 4.521ms (±0.00%) | 4.707ms (±0.00%) | -3.95%    | 5.031mb         | 5.031mb    | 0.00%       |
| benchBoth ()   | 6.836ms (±0.00%) | 6.879ms (±0.00%) | -0.62%    | 4.883mb         | 4.877mb    | +0.13%      |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+

SplitStreamBench
================

+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                         | time (kde mode)                                     | memory                                     |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                 | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad10000Events () | 5.649ms (±0.00%)   | 5.654ms (±0.00%)   | -0.10%    | 35.649mb        | 35.649mb   | 0.00%       |
| benchSave10000Events () | 356.606ms (±0.00%) | 354.646ms (±0.00%) | +0.55%    | 35.652mb        | 35.651mb   | +0.00%      |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SubscriptionEngineBench
=======================

+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                               | memory                                     |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>  | Tag: base       | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 3.356s (±0.00%) | 3.368s (±0.00%) | -0.35%    | 47.560mb        | 47.560mb   | 0.00%       |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+

SimpleSetupStreamStoreBench
===========================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.150ms (±0.00%)   | 1.130ms (±0.00%)   | +1.71%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchLoad10000Events ()                | 71.254ms (±0.00%)  | 70.770ms (±0.00%)  | +0.68%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave1Event ()                     | 1.332ms (±0.00%)   | 1.229ms (±0.00%)   | +8.39%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000Events ()                | 304.726ms (±0.00%) | 304.560ms (±0.00%) | +0.05%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.493s (±0.00%)    | 8.578s (±0.00%)    | -0.99%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 5.507s (±0.00%)    | 5.490s (±0.00%)    | +0.31%    | 35.206mb        | 35.206mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SubscriptionEngineBatchBench
============================

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 83.558ms (±0.00%) | 84.095ms (±0.00%) | -0.64%    | 35.544mb        | 35.544mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

PersonalDataBench
=================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.230ms (±0.00%)   | 1.266ms (±0.00%)   | -2.87%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchLoad10000Events ()                | 99.899ms (±0.00%)  | 100.389ms (±0.00%) | -0.49%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave1Event ()                     | 1.813ms (±0.00%)   | 1.879ms (±0.00%)   | -3.54%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave10000Events ()                | 264.695ms (±0.00%) | 267.917ms (±0.00%) | -1.20%    | 35.586mb        | 35.586mb   | 0.00%       |
| benchSave10000Aggregates ()            | 12.880s (±0.00%)   | 12.927s (±0.00%)   | -0.36%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 9.788s (±0.00%)    | 9.793s (±0.00%)    | -0.05%    | 36.044mb        | 36.044mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

This comment gets update everytime a new commit comes in!