Skip to content

Commit

Permalink
README fix
Browse files Browse the repository at this point in the history
  • Loading branch information
dzhdmitry committed Apr 15, 2021
1 parent 4b044dd commit c6397cd
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ use Dzhdmitry\TinkoffInvestApi\Streaming\Schema\Response\AbstractResponse;
use Dzhdmitry\TinkoffInvestApi\Streaming\Connection;
use Dzhdmitry\TinkoffInvestApi\Streaming\WebsocketConnectionFactory;

Amp\Loop::run(function () {
\Amp\Loop::run(function () {
// Объект ResponseDeserializer можно использовать для десериализации ответов сервера
$deserializer = (new ResponseDeserializerFactory())->create();

Expand All @@ -136,7 +136,7 @@ Amp\Loop::run(function () {
$i = 0;

while ($message = yield $connection->receive()) {
/** @var Amp\Websocket\Message $message полученное из WebSocket сообщение */
/** @var \Amp\Websocket\Message $message полученное из WebSocket сообщение */
/** @var AbstractResponse $response десериализованное тело сообщения */
$response = $deserializer->deserialize(yield $message->buffer());

Expand All @@ -158,7 +158,7 @@ Amp\Loop::run(function () {
}

// Получать каждое сообщение с интервалом в 1 сек
yield Amp\delay(1000);
yield \Amp\delay(1000);
}
});
```
Expand Down

0 comments on commit c6397cd

Please sign in to comment.