appserver-io / server

     * @return string

     * @throws \AppserverIo\Psr\Socket\SocketReadTimeoutException

     */

    public function readLine($readLength = 1024, $receiveTimeout = null)

    {

        if ($receiveTimeout) {

            // set timeout for read data fom client

            @stream_set_timeout($this->getConnectionResource(), $receiveTimeout);

        }

        $line = @fgets($this->getConnectionResource(), $readLength);

        // check if read error occured

        if ($line === false) {

            throw new SocketReadException();

        }

        // check if timeout occurred

        if (strlen($line) === 0) {

            throw new SocketReadTimeoutException();

        }

        return $line;

    }

    /**

     * Reads the given length from connection resource

     * @throws \AppserverIo\Psr\Socket\SocketReadTimeoutException

     * @throws \AppserverIo\Psr\Socket\SocketReadException

     */

    public function read($readLength = 1024, $receiveTimeout = null)

    {

        if ($receiveTimeout) {

            // set timeout for read data fom client

            @stream_set_timeout($this->getConnectionResource(), $receiveTimeout);

        }

        // read in line from client

        $line = @fread($this->getConnectionResource(), $readLength);

        // check if false is response

        if (false === $line) {

            // throw new socket exception

            throw new SocketReadException();

        }

        // check if timeout occurred

        if (strlen($line) === 0) {

            throw new SocketReadTimeoutException();

        }

        return $line;

    }

    /**

     * Writes the given message to the connection resource.