fix log output end of stream in subscription engine

[DavidBadura]

No description provided.

[github-actions]

Hello 👋

here is the most recent benchmark result:

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

+---------------------------+-----------------+-----------------+-----------------+------------+
|                           | time (kde mode)                   | memory                       |
+---------------------------+-----------------+-----------------+-----------------+------------+
| subject                   | Tag: <current>  | Tag: base       | Tag: <current>  | Tag: base  |
+---------------------------+-----------------+-----------------+-----------------+------------+
| benchHandle10000Events () | 3.292s (±0.00%) | 3.303s (±0.00%) | 37.782mb        | 37.782mb   |
+---------------------------+-----------------+-----------------+-----------------+------------+

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

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events ()                | 237.131ms (±0.00%) | 241.062ms (±0.00%) | 39.997mb        | 39.997mb   |
| benchSave1Event ()                     | 1.420ms (±0.00%)   | 1.383ms (±0.00%)   | 39.997mb        | 39.997mb   |
| benchSave10000Events ()                | 474.818ms (±0.00%) | 484.724ms (±0.00%) | 40.000mb        | 40.000mb   |
| benchSave10000Aggregates ()            | 13.956s (±0.00%)   | 14.054s (±0.00%)   | 39.997mb        | 39.997mb   |
| benchSave10000AggregatesTransaction () | 11.812s (±0.00%)   | 11.725s (±0.00%)   | 40.499mb        | 40.499mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

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

+-------------------------+--------------------+--------------------+-----------------+------------+
|                         | time (kde mode)                         | memory                       |
+-------------------------+--------------------+--------------------+-----------------+------------+
| subject                 | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+-------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events () | 5.540ms (±0.00%)   | 5.834ms (±0.00%)   | 41.234mb        | 41.234mb   |
| benchSave10000Events () | 555.573ms (±0.00%) | 566.029ms (±0.00%) | 41.245mb        | 41.245mb   |
+-------------------------+--------------------+--------------------+-----------------+------------+

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

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events ()                | 159.661ms (±0.00%) | 158.055ms (±0.00%) | 37.343mb        | 37.343mb   |
| benchSave1Event ()                     | 943.300μs (±0.00%) | 928.200μs (±0.00%) | 37.343mb        | 37.343mb   |
| benchSave10000Events ()                | 401.244ms (±0.00%) | 406.594ms (±0.00%) | 37.343mb        | 37.343mb   |
| benchSave10000Aggregates ()            | 9.233s (±0.00%)    | 9.426s (±0.00%)    | 37.343mb        | 37.343mb   |
| benchSave10000AggregatesTransaction () | 7.438s (±0.00%)    | 7.438s (±0.00%)    | 37.343mb        | 37.343mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

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

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000EventsMissingSnapshot () | 157.131ms (±0.00%) | 162.401ms (±0.00%) | 37.361mb        | 37.361mb   |
| benchLoad10000Events ()                | 515.200μs (±0.00%) | 531.100μs (±0.00%) | 37.361mb        | 37.361mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

This comment gets update everytime a new commit comes in!