| Server IP : 78.140.185.180 / Your IP : 18.220.98.157 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/www/vendor/predis/predis/src/Protocol/Text/ |
Upload File : |
<?php
/*
* This file is part of the Predis package.
*
* (c) Daniele Alessandri <suppakilla@gmail.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Predis\Protocol\Text;
use Predis\Command\CommandInterface;
use Predis\Connection\CompositeConnectionInterface;
use Predis\Protocol\ProtocolProcessorInterface;
use Predis\Protocol\RequestSerializerInterface;
use Predis\Protocol\ResponseReaderInterface;
/**
* Composite protocol processor for the standard Redis wire protocol using
* pluggable handlers to serialize requests and deserialize responses.
*
* @link http://redis.io/topics/protocol
*
* @author Daniele Alessandri <suppakilla@gmail.com>
*/
class CompositeProtocolProcessor implements ProtocolProcessorInterface
{
/*
* @var RequestSerializerInterface
*/
protected $serializer;
/*
* @var ResponseReaderInterface
*/
protected $reader;
/**
* @param RequestSerializerInterface $serializer Request serializer.
* @param ResponseReaderInterface $reader Response reader.
*/
public function __construct(
RequestSerializerInterface $serializer = null,
ResponseReaderInterface $reader = null
) {
$this->setRequestSerializer($serializer ?: new RequestSerializer());
$this->setResponseReader($reader ?: new ResponseReader());
}
/**
* {@inheritdoc}
*/
public function write(CompositeConnectionInterface $connection, CommandInterface $command)
{
$connection->writeBuffer($this->serializer->serialize($command));
}
/**
* {@inheritdoc}
*/
public function read(CompositeConnectionInterface $connection)
{
return $this->reader->read($connection);
}
/**
* Sets the request serializer used by the protocol processor.
*
* @param RequestSerializerInterface $serializer Request serializer.
*/
public function setRequestSerializer(RequestSerializerInterface $serializer)
{
$this->serializer = $serializer;
}
/**
* Returns the request serializer used by the protocol processor.
*
* @return RequestSerializerInterface
*/
public function getRequestSerializer()
{
return $this->serializer;
}
/**
* Sets the response reader used by the protocol processor.
*
* @param ResponseReaderInterface $reader Response reader.
*/
public function setResponseReader(ResponseReaderInterface $reader)
{
$this->reader = $reader;
}
/**
* Returns the Response reader used by the protocol processor.
*
* @return ResponseReaderInterface
*/
public function getResponseReader()
{
return $this->reader;
}
}