Fixed bug that retry_interval does not work for rpc-multiplex. (#3794)

Author: limingxinleo

src/Transporter.php

@@ -41,7 +41,7 @@ class Transporter implements TransporterInterface
         ],
         'recv_timeout' => 5.0,
         'retry_count' => 2,
-        'retry_interval' => 100,
+        'retry_interval' => 0,
         'client_count' => 4,
     ];
 
@@ -55,6 +55,7 @@ public function __construct(ContainerInterface $container, array $config = [])
     public function send(string $data)
     {
         $retryCount = $this->config['retry_count'] ?? 2;
+        $retryInterval = $this->config['retry_interval'] ?? 0;
         $result = retry($retryCount, function () use ($data) {
             try {
                 return $this->factory->get()->request($data);
@@ -65,7 +66,7 @@ public function send(string $data)
 
                 return new ExceptionThrower($exception);
             }
-        });
+        }, $retryInterval);
 
         if ($result instanceof ExceptionThrower) {
             throw $result->getThrowable();

tests/Cases/TransporterTest.php

@@ -39,12 +39,15 @@ public function testConfig()
 
         $transporter = new Transporter($container, [
             'connect_timeout' => $timeout = rand(50, 100),
+            'retry_interval' => 123,
         ]);
 
         $invoker = new ClassInvoker($transporter);
         $this->assertSame($timeout, $invoker->config['connect_timeout']);
 
         $factory = new ClassInvoker($invoker->factory);
         $this->assertSame($timeout, $factory->config['connect_timeout']);
+
+        $this->assertSame(123, $factory->config['retry_interval']);
     }
 }