nsq/nsq-bundle
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Refactoring: Simplify NsqTransport::get

Browse Source
This commit is contained in:
Konstantin Grachev
2021-03-11 11:10:50 +03:00
parent ae00cdb763
commit 564fdd2be0
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/Messenger/NsqTransport.php
View File

@ -74,16 +74,14 @@ final class NsqTransport implements TransportInterface
*/ */
public function get(): iterable public function get(): iterable
{ {
$message = array_pop($this->messages); if ([] === $this->messages) {
if (null === $message) {
$this->getConsumer(); $this->getConsumer();
wait(delay(500)); wait(delay(500));
$message = array_pop($this->messages);
} }
$message = array_pop($this->messages);
if (null === $message) { if (null === $message) {
return []; return [];
} }