Sha256: 7fcee8a8ea170fc470ceefb108d9eb38c49d8a1eb63aeb224a93d0a02fa3ddb3
Contents?: true
Size: 957 Bytes
Versions: 7
Compression:
Stored size: 957 Bytes
Contents
<?php namespace Predis\Pipeline; use Predis\ServerException; use Predis\Network\IConnection; class StandardExecutor implements IPipelineExecutor { public function execute(IConnection $connection, &$commands) { $sizeofPipe = count($commands); $values = array(); foreach ($commands as $command) { $connection->writeCommand($command); } try { for ($i = 0; $i < $sizeofPipe; $i++) { $response = $connection->readResponse($commands[$i]); $values[] = $response instanceof \Iterator ? iterator_to_array($response) : $response; unset($commands[$i]); } } catch (ServerException $exception) { // Force disconnection to prevent protocol desynchronization. $connection->disconnect(); throw $exception; } return $values; } }
Version data entries
7 entries across 7 versions & 1 rubygems