Thruster\Component\Stream\ThroughStream

Complexity

Total Complexity

5

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	filter()	0	4	1
A	write()	0	4	1
A	__construct()	0	7	1
A	end()	0	8	2

<?php

namespace Thruster\Component\Stream;

/**
 * Class ThroughStream
 *
 * @package Thruster\Component\Stream
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
class ThroughStream extends CompositeStream
{
    public function __construct()
    {
        $readable = new ReadableStream();
        $writable = new WritableStream();

        parent::__construct($readable, $writable);
    }

    public function filter($data)
    {
        return $data;
    }

    /**
     * {@inheritDoc}
     */
    public function write($data)
    {
        $this->readable->emit('data', [$this->filter($data), $this]);
    }

    /**
     * {@inheritDoc}
     */
    public function end($data = null)
    {
        if (null !== $data) {
            $this->readable->emit('data', [$this->filter($data), $this]);
        }

        $this->writable->end($data);
    }
}