diff --git a/composer.json b/composer.json index 124d717..e38d571 100644 --- a/composer.json +++ b/composer.json @@ -16,7 +16,7 @@ "files": ["src/inc.php"] }, "require": { - "krak/mw": "^0.1.0", + "krak/mw": "^0.3.0", "nikic/iter": "^1.4", "psr/log": "^1.0", "symfony/process": "^2.8" diff --git a/src/AbstractPipeline.php b/src/AbstractPipeline.php index 78a6146..49769ad 100644 --- a/src/AbstractPipeline.php +++ b/src/AbstractPipeline.php @@ -2,7 +2,7 @@ namespace Krak\Job; -use function Krak\Mw\composeMwSet; +use Krak\Mw; /** manages a stack of consumers to form a pipeline. Consumers at the end will be executed first */ abstract class AbstractPipeline @@ -27,6 +27,6 @@ public function shift() { return array_shift($this->middleware); } public function compose() { - return composeMwSet($this->middleware); + return mw\compose($this->middleware); } } diff --git a/src/ConsumerPipeline.php b/src/ConsumerPipeline.php index 4845477..dbbf3ad 100644 --- a/src/ConsumerPipeline.php +++ b/src/ConsumerPipeline.php @@ -2,8 +2,6 @@ namespace Krak\Job; -use function Krak\Mw\composeMwSet; - /** manages a stack of consumers to form a pipeline. Consumers at the end will be executed first */ class ConsumerPipeline extends AbstractPipeline { diff --git a/src/ProducerPipeline.php b/src/ProducerPipeline.php index f71273c..a01a3ca 100644 --- a/src/ProducerPipeline.php +++ b/src/ProducerPipeline.php @@ -2,8 +2,6 @@ namespace Krak\Job; -use function Krak\Mw\composeMwSet; - /** manages a stack of producers to form a pipeline. Producers at the end will be executed first */ class ProducerPipeline extends AbstractPipeline {