Use Hyperf\Coroutine\Channel\Pool instead of Hyperf\Utils\ChannelPool (#5671)

Author: huangdijia

composer.json

@@ -19,8 +19,8 @@
  "require": {
  "php": ">=8.0",
  "hyperf/code-parser": "~3.0.0",
+ "hyperf/coroutine": "~3.0.0",
  "hyperf/grpc": "~3.0.0",
- "hyperf/utils": "~3.0.0",
  "jean85/pretty-package-versions": "^1.2|^2.0"
  },
  "autoload": {

src/BaseClient.php

@@ -13,10 +13,10 @@
 
 use Google\Protobuf\Internal\Message;
 use Hyperf\Context\ApplicationContext;
+use Hyperf\Coroutine\Channel\Pool as ChannelPool;
 use Hyperf\Grpc\Parser;
 use Hyperf\Grpc\StatusCode;
 use Hyperf\GrpcClient\Exception\GrpcClientException;
-use Hyperf\Utils\ChannelPool;
 use InvalidArgumentException;
 use Swoole\Http2\Response;
 

src/GrpcClient.php

@@ -11,11 +11,11 @@
  */
 namespace Hyperf\GrpcClient;
 
+use Hyperf\Coroutine\Channel\Pool as ChannelPool;
 use Hyperf\Coroutine\Coroutine;
 use Hyperf\Engine\Channel;
 use Hyperf\Grpc\StatusCode;
 use Hyperf\GrpcClient\Exception\GrpcClientException;
-use Hyperf\Utils\ChannelPool;
 use InvalidArgumentException;
 use RuntimeException;
 use Swoole\Coroutine\Http2\Client as SwooleHttp2Client;

tests/BaseClientTest.php

@@ -13,13 +13,13 @@
 
 use Grpc\UserReply;
 use Hyperf\Context\ApplicationContext;
+use Hyperf\Coroutine\Channel\Pool as ChannelPool;
 use Hyperf\Coroutine\Coroutine;
 use Hyperf\Coroutine\Parallel;
 use Hyperf\Di\Container;
 use Hyperf\Grpc\Parser;
 use Hyperf\GrpcClient\BaseClient;
 use Hyperf\GrpcClient\Exception\GrpcClientException;
-use Hyperf\Utils\ChannelPool;
 use HyperfTest\GrpcClient\Stub\HiClient;
 use Mockery;
 use PHPUnit\Framework\TestCase;

tests/GoUserServiceTest.php

@@ -12,8 +12,8 @@
 namespace HyperfTest\GrpcClient;
 
 use Hyperf\Context\ApplicationContext;
+use Hyperf\Coroutine\Channel\Pool as ChannelPool;
 use Hyperf\Di\Container;
-use Hyperf\Utils\ChannelPool;
 use HyperfTest\GrpcClient\Stub\UserServiceClient;
 use Mockery;
 use PHPUnit\Framework\TestCase;

tests/RouteGuideClientTest.php

@@ -12,10 +12,10 @@
 namespace HyperfTest\GrpcClient;
 
 use Hyperf\Context\ApplicationContext;
+use Hyperf\Coroutine\Channel\Pool as ChannelPool;
 use Hyperf\Di\Container;
 use Hyperf\GrpcClient\Exception\GrpcClientException;
 use Hyperf\GrpcClient\StreamingCall;
-use Hyperf\Utils\ChannelPool;
 use HyperfTest\GrpcClient\Stub\RouteGuideClient;
 use Mockery;
 use PHPUnit\Framework\TestCase;