Add pipe & reducer

[DavidBadura]

Add two new components: Pipe and Reducer

Pipe

The Pipe is a construct that allows you to chain multiple translators.
This can be used to manipulate, filter or expand messages or events.
This can be used for anti-corruption layers, data migration, or to fix errors in the event stream.

$messages = new Pipe(
    [$message1, $message2, /* ... */],
    new ExcludeEventTranslator(ProfileVisited::class)),
);

foreach ($messages as $message) {
  // do something
}

Reducer

The Reducer is a construct that allows you to reduce messages to a state.
This can be used to build temporal projections or to create a read model.

$state = (new Reducer())
    ->initState(['name' => 'unknown'])
    ->match([
        ProfileCreated::class => static function (Message $message): array {
            return ['name' => $message->event()->name];
        },
        NameChanged::class => static function (Message $message): array {
            return ['name' => $message->event()->name];
        },
    ])
    ->reduce(
        new Pipe(
            $store->load(new Criteria(
                new AggregateIdCriterion($profileId->toString()),
                new AggregateNameCriterion('profile'),
            )),
            new UntilEventTranslator(new DateTimeImmutable()),
        ),
    );

[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.082s (±0.00%) | 3.088s (±0.00%) | -0.18%    | 34.234mb        | 34.742mb   | -1.46%      |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+

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

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 70.266ms (±0.00%) | 69.019ms (±0.00%) | +1.81%    | 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 ()                     | 944.900μs (±0.00%) | 892.800μs (±0.00%) | +5.84%    | 34.744mb        | 34.744mb   | 0.00%       |
| benchLoad10000Events ()                | 46.662ms (±0.00%)  | 47.126ms (±0.00%)  | -0.98%    | 34.744mb        | 34.744mb   | 0.00%       |
| benchSave1Event ()                     | 1.101ms (±0.00%)   | 939.200μs (±0.00%) | +17.21%   | 34.744mb        | 34.744mb   | 0.00%       |
| benchSave10000Events ()                | 226.426ms (±0.00%) | 228.536ms (±0.00%) | -0.92%    | 34.744mb        | 34.744mb   | 0.00%       |
| benchSave10000Aggregates ()            | 7.727s (±0.00%)    | 7.693s (±0.00%)    | +0.45%    | 34.744mb        | 34.744mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 4.801s (±0.00%)    | 4.792s (±0.00%)    | +0.19%    | 34.744mb        | 34.744mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

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

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad10000EventsMissingSnapshot () | 48.251ms (±0.00%)  | 48.594ms (±0.00%)  | -0.71%    | 33.836mb        | 33.836mb   | 0.00%       |
| benchLoad10000Events ()                | 941.900μs (±0.00%) | 938.400μs (±0.00%) | +0.37%    | 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.548ms (±0.00%)   | 4.515ms (±0.00%)   | +0.74%    | 37.072mb        | 37.072mb   | 0.00%       |
| benchSave10000Events () | 356.380ms (±0.00%) | 368.852ms (±0.00%) | -3.38%    | 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 ()                     | 901.500μs (±0.00%) | 896.400μs (±0.00%) | +0.57%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchLoad10000Events ()                | 84.481ms (±0.00%)  | 83.268ms (±0.00%)  | +1.46%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchSave1Event ()                     | 1.542ms (±0.00%)   | 1.466ms (±0.00%)   | +5.16%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchSave10000Events ()                | 266.214ms (±0.00%) | 270.823ms (±0.00%) | -1.70%    | 34.897mb        | 34.897mb   | 0.00%       |
| benchSave10000Aggregates ()            | 11.977s (±0.00%)   | 12.000s (±0.00%)   | -0.19%    | 34.895mb        | 34.895mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 8.939s (±0.00%)    | 8.930s (±0.00%)    | +0.10%    | 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 ()                     | 965.700μs (±0.00%) | 975.800μs (±0.00%) | -1.04%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchLoad10000Events ()                | 50.878ms (±0.00%)  | 48.654ms (±0.00%)  | +4.57%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave1Event ()                     | 1.195ms (±0.00%)   | 944.800μs (±0.00%) | +26.43%   | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave10000Events ()                | 234.461ms (±0.00%) | 236.146ms (±0.00%) | -0.71%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave10000Aggregates ()            | 7.561s (±0.00%)    | 7.795s (±0.00%)    | -3.00%    | 33.765mb        | 33.765mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 4.796s (±0.00%)    | 4.802s (±0.00%)    | -0.13%    | 33.765mb        | 33.765mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

This comment gets update everytime a new commit comes in!