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