Cassandra\Response\ResultIterator

Complexity

Total Complexity

9

Size/Duplication

Total Lines	100
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	key()	0	3	1
A	next()	0	3	1
A	rewind()	0	4	1
A	valid()	0	3	2
A	__construct()	0	7	1
A	current()	0	10	3

<?php

namespace Cassandra\Response;

/**
 * @author Dennis Birkholz <birkholz@pubgrade.com>
 */
class ResultIterator implements \Iterator {
    /**
     * Stream containing the raw result data
     * 
     * @var StreamReader
     */
    private $stream;
    
    /**
     * Offset to start reading data in this stream
     * 
     * @var int
     */
    private $offset;
    
    /**
     * Metadata generated by the creating Result
     * 
     * @var array
     */
    private $metadata;
    
    /**
     * Class to use for each row of data
     * 
     * @var string
     */
    private $rowClass;
    
    /**
     * Number of available rows in the resultset
     * 
     * @var int
     */
    private $count;
    
    /**
     * Current row
     * 
     * @var int
     */
    private $row = 0;
    
    
    public function __construct(StreamReader $stream, array $metadata, $rowClass) {

The parameter $rowClass is not used and could be removed.

        $this->stream = clone $stream;
        $this->metadata = $metadata;
        $this->count = $this->stream->readInt();
        $this->offset = $this->stream->pos();
        $this->rewind();
    }

    public function current() {
        $data = [];
        
        foreach ($this->metadata['columns'] as $column) {
            $data[$column['name']] = $this->stream->readValue($column['type']);
        }
        
        $rowClass = $this->rowClass;
        return ($rowClass === null ? $data : new $rowClass($data));
    }

    /**
     * The current position in this result set
     * 
     * @return int
     */
    public function key() {
        return $this->row;
    }

    /**
     * Move forward to next element
     * 
     * @return void
     */
    public function next() {
        $this->row++;
    }

    /**
     * Reset the result set
     * 
     * @return void
     */
    public function rewind() {
        $this->row = 0;
        $this->stream->offset($this->offset);
    }

    /**
     * Checks if current position is valid
     * 
     * @return boolean
     */
    public function valid() {
        return (($this->row >= 0) && ($this->row < $this->count));
    }
}