for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Thruster\Component\Stream;
/**
* Class ThroughStream
*
* @package Thruster\Component\Stream
* @author Aurimas Niekis <[email protected]>
*/
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]);
public function end($data = null)
if (null !== $data) {
$this->writable->end($data);
ThrusterIO /
stream
