for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/**
* Async sockets
*
* @copyright Copyright (c) 2015-2017, Efimov Evgenij <[email protected]>
* This source file is subject to the MIT license that is bundled
* with this source code in the file LICENSE.
*/
namespace AsyncSockets\Socket\Io;
use AsyncSockets\Frame\FramePickerInterface;
use AsyncSockets\Socket\SocketInterface;
* Class DatagramMemorizedIo
class DatagramMemorizedIo extends DatagramClientIo
{
* Data for this socket
* @var string
private $data;
* Constructor
* @param SocketInterface $socket Socket object
* @param string $remoteAddress Destination address in form scheme://host:port
* @param string $data Datagram for this socket
public function __construct(SocketInterface $socket, $remoteAddress, $data)
parent::__construct($socket, $remoteAddress);
$this->data = (string) $data;
}
/** {@inheritdoc} */
protected function readRawDataIntoPicker(FramePickerInterface $picker, $isOutOfBand)
$data = $this->data;
$this->data = '';
return $picker->pickUpData($data, $this->remoteAddress);
edefimov /
async-sockets
