改名

2020-10-09 18:35:41 +08:00
parent 10e0bdc93b
commit 3722595c36
1 changed files with 6 additions and 3 deletions
@@ -14,16 +14,18 @@

 namespace Kafka;

+use function Amp\run;
+
 /**
-+------------------------------------------------------------------------------
+ * +------------------------------------------------------------------------------
 * Kafka protocol since Kafka v0.8
-+------------------------------------------------------------------------------
+* +------------------------------------------------------------------------------
 *
 * @package
 * @version $_SWANBR_VERSION_$
 * @copyright Copyleft
 * @author $_SWANBR_AUTHOR_$
-+------------------------------------------------------------------------------
+* +------------------------------------------------------------------------------
 */

 class Consumer
@@ -73,6 +75,7 @@ class Consumer
        }
        $process->start();
        $this->isRunning = true;
+        run();
    }

    // }}}