* * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace Predis\Iterators; /** * Abstracts the access to a streamable list of tuples represented * as a multibulk reply that alternates keys and values. * * @author Daniele Alessandri */ class MultiBulkResponseTuple extends MultiBulkResponse implements \OuterIterator { private $iterator; /** * @param MultiBulkResponseSimple $iterator Multibulk reply iterator. */ public function __construct(MultiBulkResponseSimple $iterator) { $virtualSize = count($iterator) / 2; $this->iterator = $iterator; $this->position = $iterator->getPosition(); $this->current = $virtualSize > 0 ? $this->getValue() : null; $this->replySize = $virtualSize; } /** * {@inheritdoc} */ public function getInnerIterator() { return $this->iterator; } /** * {@inheritdoc} */ public function __destruct() { $this->iterator->sync(true); } /** * {@inheritdoc} */ protected function getValue() { $k = $this->iterator->current(); $this->iterator->next(); $v = $this->iterator->current(); $this->iterator->next(); return array($k, $v); } }