Skip to content

Commit 73f751a

Browse files
committed
Merge branch '2.0'
2 parents 9fb0694 + 175652c commit 73f751a

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

examples/process/queue.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111

1212
$queue = new \FastD\Swoole\Queue('queue', function ($worker) {
1313
while (true) {
14+
echo get_class($worker);
1415
$recv = $worker->pop();
1516
echo "From Master: $recv\n";
1617
}

src/Process.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ public function fork($length = 1)
219219
$this->start();
220220
// new sub process
221221
for ($i = 0; $i < $length; $i++) {
222-
$process = new static($this->name, $this->callback, $this->stdout, $this->pipe);
222+
$process = new static($this->name, $this->callback, $this->redirect, $this->pipe);
223223
if (!empty($this->name)) {
224224
$process->name($this->name . ' worker');
225225
}

0 commit comments

Comments
 (0)