as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-10 11:31:23 +08:00
parent bc8905c863
commit bfc507782d
1 changed files with 23 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+2
View File
@@ -63,6 +63,7 @@ class Kafka extends \Snowflake\Process\Process
*/ */
public function initCoroutine() public function initCoroutine()
{ {
go(function () {
$group = new WaitGroup(); $group = new WaitGroup();
while ([$topic, $part, $message] = $this->channel->pop()) { while ([$topic, $part, $message] = $this->channel->pop()) {
try { try {
@@ -86,6 +87,7 @@ class Kafka extends \Snowflake\Process\Process
} }
} }
$group->wait(); $group->wait();
});
} }