Deleted useless timeout.

hyperf · Nov 6, 2019 · f491612 · f491612
1 parent 911d2f0
commit f491612
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/nats/src/Driver/NatsDriver.php b/src/nats/src/Driver/NatsDriver.php
@@ -74,14 +74,15 @@ public function request(string $subject, $payload, Closure $callback)
         }
     }
 
-    public function requestSync(string $subject, $payload, float $timeout = 10.0): Message
+    public function requestSync(string $subject, $payload): Message
     {
         try {
             /** @var Connection $connection */
             $connection = $this->pool->get();
             /** @var NatsConnection $client */
             $client = $connection->getConnection();
             $channel = new Channel(1);
+            $timeout = floatval($this->config['timeout'] ?? 1.0);
             $client->request($subject, $payload, function (Message $message) use ($channel) {
                 $channel->push($message);
             });