Wallogit.com
2017 © Pedro Peláez
A PHP package to invoke parallel closure or invokable class instance
, (*1)
This library provides ability to run callbacks/closure/invokable instance in parallel., (*2)
use Gandung\Pipeline\Pipeline;
// Closure based task.
$pipe = (new Pipeline)
->pipe(function($q) { return $q; })
->pipe(function($q) { return join(' ', [$q, 'bar']); })
->pipe(function($q) { return join(' ', [$q, 'baz']); });
$payload = $pipe->invokeAll('foo');
echo sprintf("%s\n", $payload);
This will print 'foo bar baz'. This equals to $task3($task2($task1('foo')))., (*3)
use Gandung\Pipeline\Pipeline;
use Gandung\Pipeline\Tests\Fixtures\FooTask;
use Gandung\Pipeline\Tests\Fixtures\BarTask;
use Gandung\Pipeline\Tests\Fixtures\BazTask;
// Instance based task. Class instance must implements __invoke and TaskInterface class interface.
$pipe = (new Pipeline)
->pipe(new FooTask)
->pipe(new BarTask)
->pipe(new BazTask);
$payload = $pipe->invokeAll('foo');
echo sprintf("%s\n", $payload);
This will print the same result as above., (*4)
use Gandung\Pipeline\PipelineBuilder;
// Closure based task.
$builder = (new PipelineBuilder)
->add(function($q) { return $q; })
->add(function($q) { return join(' ', [$q, 'bar']); })
->add(function($q) { return join(' ', [$q, 'baz']); });
$pipe = $builder->build();
$payload = $pipe->invokeAll('foo');
echo sprintf("%s\n", $payload);
use Gandung\Pipeline\PipelineBuilder;
use Gandung\Pipeline\Tests\Fixtures\FooTask;
use Gandung\Pipeline\Tests\Fixtures\BarTask;
use Gandung\Pipeline\Tests\Fixtures\BazTask;
// Instance based task. Class instance must implements __invoke and TaskInterface class interface.
$builder = (new PipelineBuilder)
->add(new FooTask)
->add(new BarTask)
->add(new BazTask);
$pipe = $builder->build();
$payload = $pipe->invokeAll('foo');
echo sprintf("%s\n", $payload);
__construct($tasks = [], ProcessorInterface $processor = null), (*5)
$tasks The tasks, can be list of closure/class instance, defaulting to empty array\Gandung\Pipeline\ProcessorInterface $processor The class instance which implements ProcessorInterface, defaulting to null
None, (*6)
pipe($task), (*7)
$task The task, can be closure/class instanceAn immutable copy of \Gandung\Pipeline\Pipeline, (*8)
invokeAll($param), (*9)
$param Task parameterMixed, (*10)
add($task), (*11)
$task The task, can be closure/class instanceAn immutable copy of Gandung\Pipeline\PipelineBuilder, (*12)
build(ProcessorInterface $processor = null), (*13)
\Gandung\Pipeline\ProcessorInterface $processor The class instance which implements ProcessorInterface, defaulting to null
An instance of \Gandung\Pipeline\Pipeline, (*14)
invoke($tasks, $param), (*15)
$tasks The tasks, can be list of closure/class instance$param Task parameterMixed, (*16)
resume(), (*17)
None, (*18)
None, (*19)
freeze(), (*20)
None, (*21)
None, (*22)
interrupt(), (*23)
None, (*24)
None, (*25)
pause(), (*26)
None, (*27)
None, (*28)
getState(), (*29)
None, (*30)
Current task state., (*31)
__construct($routine), (*32)
$routine Cancellation routine, must return true or false
None, (*33)
invoke($tasks, $param), (*34)
$tasks The tasks, can be list of closure/class instance$param Task parameterMixed, (*35)
resume(), (*36)
None, (*37)
None, (*38)
freeze(), (*39)
None, (*40)
None, (*41)
interrupt(), (*42)
None, (*43)
None, (*44)
pause(), (*45)
None, (*46)
None, (*47)
getState(), (*48)
None, (*49)
Current task state., (*50)
__construct($routine = null), (*51)
$routine Cancellation routine, must return true or false, defaulting to null
None, (*52)
invoke($tasks, $param), (*53)
$tasks The tasks, can be list of closure/class instance$param Task parameterMixed, (*54)
resume(), (*55)
None, (*56)
None, (*57)
pause(), (*58)
None, (*59)
None, (*60)
interrupt(), (*61)
None, (*62)
None, (*63)
freeze(), (*64)
None, (*65)
None, (*66)
getState(), (*67)
None, (*68)
Current task state., (*69)
A PHP package to invoke parallel closure or invokable class instance
BSD-3-Clause
A PHP package to invoke parallel closure or invokable class instance
BSD-3-Clause
A PHP package to invoke parallel closure or invokable class instance
BSD-3-Clause