test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-12-05 05:07:58 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

Deleted useless timeout.

Browse Source
This commit is contained in:
李铭昕 2019-11-06 13:36:17 +08:00
parent 911d2f0341
commit f491612a47
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/nats/src/Driver/NatsDriver.php
View File

@ -74,7 +74,7 @@ class NatsDriver extends AbstractDriver
}
}
public function requestSync(string $subject, $payload, float $timeout = 10.0): Message
public function requestSync(string $subject, $payload): Message
{
try {
/** @var Connection $connection */
@ -82,6 +82,7 @@ class NatsDriver extends AbstractDriver
/** @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);
});