ButterAMQP\IO\BufferIO

Complexity

Total Complexity

9

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	open()	0	4	1
A	close()	0	4	1
A	read()	0	11	2
A	write()	0	6	1
A	push()	0	6	1
A	pop()	0	12	2

<?php

namespace ButterAMQP\IO;

use ButterAMQP\IOInterface;

class BufferIO implements IOInterface
{
    /**
     * @var string
     */
    private $writeBuffer;

    /**
     * @var string
     */
    private $readBuffer;

    /**
     * @param string $readBuffer
     */
    public function __construct($readBuffer = '')
    {
        $this->readBuffer = $readBuffer;
    }

    /**
     * {@inheritdoc}
     */
    public function open($protocol, $host, $port, array $parameters = [])
    {
        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        return $this;
    }

    /**
     * {@inheritdoc}
     */
    public function read($length, $blocking = true)
    {
        if (strlen($this->readBuffer) < $length) {
            $length = strlen($this->readBuffer);
        }

        $data = substr($this->readBuffer, 0, $length);
        $this->readBuffer = substr($this->readBuffer, $length, strlen($this->readBuffer) - $length);

        return $data;
    }

    /**
     * {@inheritdoc}
     */
    public function write($data, $length = null)
    {
        $this->writeBuffer .= $data;

        return $this;
    }

    /**
     * @param string $data
     *
     * @return $this
     */
    public function push($data)
    {
        $this->readBuffer .= $data;

        return $this;
    }

    /**
     * @param null $length
     *
     * @return string
     */
    public function pop($length = null)
    {
        if ($length === null) {
            $data = $this->writeBuffer;
            $this->writeBuffer = '';
        } else {
            $data = substr($this->writeBuffer, 0, $length);
            $this->writeBuffer = substr($this->writeBuffer, $length, strlen($this->writeBuffer) - $length);
        }

        return $data;
    }
}