slickframework / cqrs-tools

    private function eventStream(ProjectorState $projectorState): Stream

    {

        switch ($projectorState->projectorRunsFrom()) {

            case Projector::RUN_FROM_NOW:

                $date = new DateTimeImmutable('now');

                $eventStream = !$projectorState->lastEvent()

                    ? $this->eventStore->allStoredEventsSince($date)

                    : $this->eventStore->allStoredEventsSince($projectorState->lastEvent());

                break;

            case Projector::RUN_FROM_BEGINNING:

                $eventStream = $projectorState->lastEvent()

                    : $this->eventStore->allStoredEventsSince($projectorState->lastEvent());

                break;

            case Projector::RUN_FROM_BEGINNING:

                $eventStream = $projectorState->lastEvent()

                    ? $this->eventStore->allStoredEventsSince($projectorState->lastEvent())

                    : $this->eventStore->allStoredEvents();

                break;

            case Projector::RUN_ONCE:

            default: