Prooph Event Store: Query event stream

Merger.php

<?php

final class Merger
{
    // ...
    private function getInitialEventFromStream(EmploymentContractId $contractId): EmploymentContractSigned
    {
        $query = $this->projectionManager->createQuery();
        $query
            ->init(function (): array {
                return [];
            })
            ->fromStream('employment_contract_stream')
            ->when([
                EmploymentContractSigned::class => function (
                    array $state, EmploymentContractSigned $event
                ) use ($contractId): array {
                    if ($event->contractId()->sameValueAs($contractId)) {
                        $state[] = $event;

                        $this->stop();
                    }

                    return $state;
                }
            ])
            ->run();

        return $query->getState()[0];
    }
}

Update fromStream for Projection, Query and ReadModelProjection:

• prooph/event-store@68a823c#diff-e3e2a9bfd88566b05001b02a3f51d286