diff --git a/System/Crontab/Consumer.php b/System/Crontab/Consumer.php index d0388951..c51c2357 100644 --- a/System/Crontab/Consumer.php +++ b/System/Crontab/Consumer.php @@ -29,7 +29,7 @@ class Consumer extends Process $process->name('Crontab consumer'); $this->channel = new Coroutine\Channel(2000); - Coroutine\go(function () { + go(function () { $this->popChannel(); }); $this->tick($process);