From d1787ad038ef397dacc74db47f5a146c041b3be1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Fri, 18 Sep 2020 16:55:09 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Console/AbstractConsole.php | 1 +
 Database/Pagination.php     | 7 +++----
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/Console/AbstractConsole.php b/Console/AbstractConsole.php
index 85f38e95..7bc73d49 100644
--- a/Console/AbstractConsole.php
+++ b/Console/AbstractConsole.php
@@ -8,6 +8,7 @@ use Exception;
 use Snowflake\Abstracts\Component;
 use Snowflake\Abstracts\Input;
 use Snowflake\Snowflake;
+use Swoole\Coroutine;
 use Swoole\Coroutine\Channel;
 
 /**
diff --git a/Database/Pagination.php b/Database/Pagination.php
index 69a99b43..dfc0aa17 100644
--- a/Database/Pagination.php
+++ b/Database/Pagination.php
@@ -118,7 +118,7 @@ class Pagination extends Component
 	public function plunk($param = [])
 	{
 		$this->_group = new Coroutine\WaitGroup();
-		$this->loop($param);
+		Coroutine::create([$this, 'loop'], $param);
 		$this->_group->wait();
 	}
 
@@ -172,16 +172,15 @@ class Pagination extends Component
 	 * @param $callback
 	 * @param $data
 	 * @param $param
-	 * @return Closure
 	 * 解释器
 	 */
 	private function executed($callback, $data, $param)
 	{
 		$this->_group->add(1);
-		return Coroutine::create(function ($callback, $data, $param) {
+		go(function () use ($callback, $data, $param) {
 			call_user_func($callback, $data, $param);
 			$this->_group->done();
-		}, $callback, $data, $param);
+		});
 	}