Slince\Process\Pipe\WritableFifo

Complexity

Total Complexity

7

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	read()	0	4	1
A	write()	0	5	1
A	getStream()	0	8	2
A	setBlocking()	0	7	2

<?php
/**
 * Process Library
 * @author Tao <taosikai@yeah.net>
 */
namespace Slince\Process\Pipe;

use Slince\Process\Exception\RuntimeException;

class WritableFifo extends AbstractFifo
{
    public function __construct($pathname, $blocking = true, $mode = 'w+', $permission = 0666)
    {
        parent::__construct($pathname, $blocking, $mode, $permission);
    }

    /**
     * {@inheritdoc}
     */
    public function read()
    {
        throw new RuntimeException("Cannot read data from an write-only fifo");
    }

    /**
     * {@inheritdoc}
     */
    public function write($message)
    {
        $stream = $this->getStream();
        return fwrite($stream, $message, strlen($message));
    }

    /**
     * {@inheritdoc}
     */
    public function getStream()
    {
        $stream = parent::getStream();
        if ($this->blocking === false) {
            stream_set_blocking($stream, false);
        }
        return $stream;
    }

    public function setBlocking($blocking)
    {
        parent::setBlocking($blocking);
        if (!is_null($this->stream)) {
            stream_set_blocking($this->stream, $blocking);
        }
    }
}