for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace tomzx\Dataflow;
use tomzx\Dataflow\Processor\Parallel\Threaded;
class Node extends Threaded {
/**
* @var callable
*/
private $callable;
* @var mixed
private $result;
* @param callable $callable
public function __construct(callable $callable)
{
$this->callable = $callable;
}
* @return mixed
public function process()
$this->result = call_user_func_array($this->callable, func_get_args());
return $this->result;
public function output()
tomzx /
dataflow
