AsyncSockets\Socket\Io\StreamedServerIo

Complexity

Total Complexity

3

Size/Duplication

Total Lines	16
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	read()	0	12	3

<?php
/**
 * Async sockets
 *
 * @copyright Copyright (c) 2015-2016, Efimov Evgenij <edefimov.it@gmail.com>
 *
 * 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\Exception\AcceptException;
use AsyncSockets\Frame\AcceptedFrame;
use AsyncSockets\Frame\FramePickerInterface;
use AsyncSockets\Socket\AcceptedSocket;

/**
 * Class StreamedServerIo
 */
class StreamedServerIo extends AbstractServerIo
{
    /** {@inheritdoc} */
    public function read(FramePickerInterface $picker)
    {
        $client = stream_socket_accept($this->socket->getStreamResource(), 0, $peerName);
        if ($client === false) {
            throw new AcceptException($this->socket, 'Can not accept client connection.');
        }

        return new AcceptedFrame(
            $peerName ?: '',
            new AcceptedSocket($client)
        );
    }
}