POC: add subscriber delay

[DavidBadura]

#[Subscriber('order.close')]
#[Delay('24h')]
class CloseOrder {
  //...
}

[github-actions]

Hello 👋

here is the most recent benchmark result:

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

+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                               | memory                                     |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>  | Tag: base       | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 3.076s (±0.00%) | 3.104s (±0.00%) | -0.90%    | 46.883mb        | 46.891mb   | -0.02%      |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+

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

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 75.505ms (±0.00%) | 74.491ms (±0.00%) | +1.36%    | 34.234mb        | 34.234mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 894.400μs (±0.00%) | 891.900μs (±0.00%) | +0.28%    | 34.744mb        | 34.744mb   | 0.00%       |
| benchLoad10000Events ()                | 47.135ms (±0.00%)  | 48.564ms (±0.00%)  | -2.94%    | 34.745mb        | 34.745mb   | 0.00%       |
| benchSave1Event ()                     | 1.052ms (±0.00%)   | 1.000ms (±0.00%)   | +5.12%    | 34.744mb        | 34.744mb   | 0.00%       |
| benchSave10000Events ()                | 212.440ms (±0.00%) | 215.751ms (±0.00%) | -1.53%    | 34.745mb        | 34.745mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.082s (±0.00%)    | 7.877s (±0.00%)    | +2.60%    | 34.745mb        | 34.745mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 4.691s (±0.00%)    | 4.750s (±0.00%)    | -1.25%    | 34.745mb        | 34.745mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad10000EventsMissingSnapshot () | 49.411ms (±0.00%)  | 48.191ms (±0.00%)  | +2.53%    | 33.836mb        | 33.836mb   | 0.00%       |
| benchLoad10000Events ()                | 920.200μs (±0.00%) | 916.700μs (±0.00%) | +0.38%    | 33.836mb        | 33.836mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                         | time (kde mode)                                     | memory                                     |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                 | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad10000Events () | 4.239ms (±0.00%)   | 4.408ms (±0.00%)   | -3.85%    | 37.072mb        | 37.072mb   | 0.00%       |
| benchSave10000Events () | 345.363ms (±0.00%) | 353.203ms (±0.00%) | -2.22%    | 37.144mb        | 37.144mb   | 0.00%       |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 903.200μs (±0.00%) | 907.500μs (±0.00%) | -0.47%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchLoad10000Events ()                | 86.046ms (±0.00%)  | 82.506ms (±0.00%)  | +4.29%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchSave1Event ()                     | 1.612ms (±0.00%)   | 1.586ms (±0.00%)   | +1.65%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchSave10000Events ()                | 248.311ms (±0.00%) | 244.959ms (±0.00%) | +1.37%    | 34.897mb        | 34.897mb   | 0.00%       |
| benchSave10000Aggregates ()            | 12.351s (±0.00%)   | 12.043s (±0.00%)   | +2.56%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 8.846s (±0.00%)    | 8.789s (±0.00%)    | +0.65%    | 35.396mb        | 35.396mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 916.000μs (±0.00%) | 916.200μs (±0.00%) | -0.02%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchLoad10000Events ()                | 48.729ms (±0.00%)  | 49.538ms (±0.00%)  | -1.63%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave1Event ()                     | 1.007ms (±0.00%)   | 1.034ms (±0.00%)   | -2.61%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave10000Events ()                | 225.428ms (±0.00%) | 218.925ms (±0.00%) | +2.97%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.725s (±0.00%)    | 7.989s (±0.00%)    | +9.21%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 4.748s (±0.00%)    | 4.752s (±0.00%)    | -0.08%    | 33.765mb        | 33.765mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

This comment gets update everytime a new commit comes in!