AsyncSockets\Socket\Io\StreamedServerIo::read()

Complexity

Conditions	3
Paths	2

Size

Total Lines	12
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	3

Importance

Changes

0

<?php
    public function read(FramePickerInterface $picker, Context $context, $isOutOfBand)
    {
        $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)
        );
    }
}