EventStreamIterator::__construct() - Code Metrics - rayrutjes/php-geteventstore-client - Measure and Improve Code Quality continuously with Scrutinizer

EventStreamIterator::__construct() A
last analyzed 2016-03-03 21:13 UTC

↳ Parent: EventStreamIterator

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Metric	Value
dl	0
loc	4
rs	10
cc	1
eloc	2
nc	1
nop	1

<?php

namespace RayRutjes\GetEventStore\Client\Http\Feed;

use RayRutjes\GetEventStore\EventRecord;

class EventStreamIterator implements \Iterator
{
    /**
     * @var EventStreamFeedIterator
     */
    private $feedIterator;

    /**
     * @var \ArrayIterator
     */
    private $eventsIterator;

    /**
     * @var int
     */
    private $currentKey;

    /**
     * @param EventStreamFeedIterator $feedIterator
     */
    public function __construct(EventStreamFeedIterator $feedIterator)
    {
        $this->feedIterator = $feedIterator;
    }

    /**
     * @return EventRecord
     */
    public function current(): EventRecord
    {
        return $this->eventsIterator->current();
    }

    public function next()
    {
        $this->eventsIterator->next();
        $this->currentKey++;
        if ($this->eventsIterator->valid()) {
            return;
        }

        $this->feedIterator->next();
        if ($this->feedIterator->valid()) {
            $this->eventsIterator = $this->newEventsIterator();
        } else {
            $this->feedIterator = null;
        }
    }

    /**
     * @return \ArrayIterator
     */
    private function newEventsIterator()
    {
        $events = $this->feedIterator->current()->getEvents();
        if ($this->feedIterator->getReadDirection()->isForward()) {
            $events = array_reverse($events);
        }

        return new \ArrayIterator($events);
    }

    /**
     * @return int
     */
    public function key()
    {
        return $this->currentKey;
    }

    /**
     * @return bool
     */
    public function valid(): bool
    {
        return $this->eventsIterator->valid();
    }

    public function rewind()
    {
        $this->currentKey = 0;
        $this->eventsIterator = $this->newEventsIterator();
    }
}


1			<?php
2
3			namespace RayRutjes\GetEventStore\Client\Http\Feed;
4
5			use RayRutjes\GetEventStore\EventRecord;
6
7			class EventStreamIterator implements \Iterator
8			{
9			/**
10			* @var EventStreamFeedIterator
11			*/
12			private $feedIterator;
13
14			/**
15			* @var \ArrayIterator
16			*/
17			private $eventsIterator;
18
19			/**
20			* @var int
21			*/
22			private $currentKey;
23
24			/**
25			* @param EventStreamFeedIterator $feedIterator
26			*/
27			public function __construct(EventStreamFeedIterator $feedIterator)
28			{
29			$this->feedIterator = $feedIterator;
30			}
31
32			/**
33			* @return EventRecord
34			*/
35			public function current(): EventRecord
36			{
37			return $this->eventsIterator->current();
38			}
39
40			public function next()
41			{
42			$this->eventsIterator->next();
43			$this->currentKey++;
44			if ($this->eventsIterator->valid()) {
45			return;
46			}
47
48			$this->feedIterator->next();
49			if ($this->feedIterator->valid()) {
50			$this->eventsIterator = $this->newEventsIterator();
51			} else {
52			$this->feedIterator = null;
53			}
54			}
55
56			/**
57			* @return \ArrayIterator
58			*/
59			private function newEventsIterator()
60			{
61			$events = $this->feedIterator->current()->getEvents();
62			if ($this->feedIterator->getReadDirection()->isForward()) {
63			$events = array_reverse($events);
64			}
65
66			return new \ArrayIterator($events);
67			}
68
69			/**
70			* @return int
71			*/
72			public function key()
73			{
74			return $this->currentKey;
75			}
76
77			/**
78			* @return bool
79			*/
80			public function valid(): bool
81			{
82			return $this->eventsIterator->valid();
83			}
84
85			public function rewind()
86			{
87			$this->currentKey = 0;
88			$this->eventsIterator = $this->newEventsIterator();
89			}
90			}
91

rayrutjes / php-geteventstore-client

EventStreamIterator::__construct() A last analyzed 2016-03-03 21:13 UTC

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like

EventStreamIterator::__construct() A
last analyzed 2016-03-03 21:13 UTC