File tree Expand file tree Collapse file tree 8 files changed +13
-5
lines changed Expand file tree Collapse file tree 8 files changed +13
-5
lines changed Original file line number Diff line number Diff line change 17
17
"hyperf/rpc-client" : " ~3.0.0" ,
18
18
"hyperf/rpc-server" : " ~3.0.0" ,
19
19
"hyperf/server" : " ~3.0.0" ,
20
+ "hyperf/support" : " ~3.0.0" ,
20
21
"hyperf/utils" : " ~3.0.0" ,
21
22
"multiplex/socket" : " ^1.0"
22
23
},
Original file line number Diff line number Diff line change 18
18
use Hyperf \RpcMultiplex \Exception \NoAvailableNodesException ;
19
19
use Psr \Container \ContainerInterface ;
20
20
21
+ use function Hyperf \Support \make ;
22
+
21
23
class SocketFactory
22
24
{
23
25
protected ?LoadBalancerInterface $ loadBalancer = null ;
Original file line number Diff line number Diff line change 37
37
use Swoole \Coroutine \Server \Connection ;
38
38
use Swoole \Server as SwooleServer ;
39
39
40
+ use function Hyperf \Support \make ;
41
+
40
42
class TcpServer extends Server
41
43
{
42
44
protected ProtocolManager $ protocolManager ;
Original file line number Diff line number Diff line change 14
14
use Hyperf \LoadBalancer \LoadBalancerInterface ;
15
15
use Hyperf \Rpc \Contract \TransporterInterface ;
16
16
use Hyperf \RpcMultiplex \Exception \NotSupportException ;
17
- use Hyperf \Utils \Exception \ExceptionThrower ;
17
+ use Hyperf \Support \Exception \ExceptionThrower ;
18
18
use Multiplex \Exception \ChannelClosedException ;
19
19
use Multiplex \Exception \ClientConnectFailedException ;
20
20
use Psr \Container \ContainerInterface ;
21
21
use Throwable ;
22
22
23
+ use function Hyperf \Support \make ;
24
+ use function Hyperf \Support \retry ;
25
+
23
26
class Transporter implements TransporterInterface
24
27
{
25
28
protected SocketFactory $ factory ;
Original file line number Diff line number Diff line change 13
13
14
14
use Hyperf \RpcMultiplex \HttpMessageBuilder ;
15
15
use Hyperf \RpcMultiplex \Packer \JsonPacker ;
16
- use Hyperf \Utils \Reflection \ClassInvoker ;
16
+ use Hyperf \Support \Reflection \ClassInvoker ;
17
17
use Psr \Http \Message \UriInterface ;
18
18
19
19
/**
Original file line number Diff line number Diff line change 18
18
use Hyperf \LoadBalancer \Random ;
19
19
use Hyperf \RpcMultiplex \Socket ;
20
20
use Hyperf \RpcMultiplex \SocketFactory ;
21
- use Hyperf \Utils \Reflection \ClassInvoker ;
21
+ use Hyperf \Support \Reflection \ClassInvoker ;
22
22
use HyperfTest \RpcMultiplex \Stub \ContainerStub ;
23
23
use Mockery ;
24
24
Original file line number Diff line number Diff line change 21
21
use Hyperf \Server \Event ;
22
22
use Hyperf \Server \Exception \InvalidArgumentException ;
23
23
use Hyperf \Server \Server ;
24
- use Hyperf \Utils \Reflection \ClassInvoker ;
24
+ use Hyperf \Support \Reflection \ClassInvoker ;
25
25
use HyperfTest \RpcMultiplex \Stub \ContainerStub ;
26
26
use Mockery ;
27
27
Original file line number Diff line number Diff line change 13
13
14
14
use Hyperf \LoadBalancer \LoadBalancerInterface ;
15
15
use Hyperf \RpcMultiplex \Transporter ;
16
- use Hyperf \Utils \Reflection \ClassInvoker ;
16
+ use Hyperf \Support \Reflection \ClassInvoker ;
17
17
use HyperfTest \RpcMultiplex \Stub \ContainerStub ;
18
18
use Mockery ;
19
19
You can’t perform that action at this time.
0 commit comments