WebStream\IO\Reader\InputStreamReader

Complexity

Total Complexity

10

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	close()	0	3	1
A	reset()	0	3	1
A	readLine()	0	3	1
A	mark()	0	3	1
A	skip()	0	3	1
A	__destruct()	0	3	1
A	read()	0	10	3
A	__construct()	0	3	1

<?php

namespace WebStream\IO\Reader;

use WebStream\Exception\Extend\InvalidArgumentException;

The type WebStream\Exception\Extend\InvalidArgumentException was not found. Maybe you did not declare it correctly or list all dependencies?

use WebStream\Exception\Extend\IOException;

The type WebStream\Exception\Extend\IOException was not found. Maybe you did not declare it correctly or list all dependencies?

use WebStream\IO\InputStream;

/**
 * InputStreamReader
 * @author Ryuichi TANAKA.
 * @since 2016/02/05
 * @version 0.7
 */
class InputStreamReader
{
    /**
     * @var InputStream 入力ストリーム
     */
    protected InputStream $stream;

    /**
     * constructor
     * @param InputStream $stream 入力ストリーム
     */
    public function __construct(InputStream $stream)
    {
        $this->stream = $stream;
    }

    /**
     * destructor
     */
    public function __destruct()
    {
        $this->close();
    }

    /**
     * 読み込んでいる入力ストリームを閉じる
     */
    public function close()
    {
        $this->stream->close();
    }

    /**
     * 入力ストリームからデータを読み込む
     * @return string 読み込みデータ
     * @throws InvalidArgumentException
     * @throws IOException
     */
    public function read()
    {
        $args = func_get_args();
        $length = count($args) === 1 ? $args[0] : 0;

        if (!is_int($length)) {
            throw new InvalidArgumentException("Invalid read size.");
        }

        return $this->stream->read($length);
    }

    /**
     * 入力ストリームから行単位でデータを読み込む
     * 末尾に改行コードは含まない
     * @return string 読み込みデータ
     */
    public function readLine()
    {
        return $this->stream->readLine();
    }

    /**
     * 入力ストリームから指定バイト数後方へポインタを移動する
     * @param int $pos 後方への移動バイト数(負数の場合は前方へ移動)
     * @return int $skipNum 移動したバイト数、移動に失敗した場合-1
     */
    public function skip(int $pos)
    {
        return $this->stream->skip($pos);
    }

    /**
     * 最後にmarkされた位置に再配置する
     * @throws IOException
     */
    public function reset()
    {
        $this->stream->reset();
    }

    /**
     * 入力ストリームの現在位置にmarkを設定する
     * @param int マークするバイト位置

The doc comment マークするバイト位置 at position 0 could not be parsed: Unknown type name 'マークするバイト位置' at position 0 in マークするバイト位置.

     * @throws IOException
     */
    public function mark()
    {
        $this->stream->mark();
    }
}