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

cs: actualize variable names

Browse Source
This commit is contained in:
Konstantin Grachev
2021-01-23 01:42:20 +03:00
parent 8725c654b2
commit b6995c8f3d
1 changed files with 39 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
tests/NsqTest.php
View File

@ -13,69 +13,69 @@ final class NsqTest extends TestCase
{ {
public function test(): void public function test(): void
{ {
$writer = new Producer('tcp://localhost:4150'); $producer = new Producer('tcp://localhost:4150');
$writer->pub(__FUNCTION__, __FUNCTION__); $producer->pub(__FUNCTION__, __FUNCTION__);
$reader = new Consumer('tcp://localhost:4150'); $consumer = new Consumer('tcp://localhost:4150');
$subscriber = new Subscriber($reader); $subscriber = new Subscriber($consumer);
$generator = $subscriber->subscribe(__FUNCTION__, __FUNCTION__, 1); $generator = $subscriber->subscribe(__FUNCTION__, __FUNCTION__, 1);
/** @var null|Message $envelope */ /** @var null|Message $message */
$envelope = $generator->current(); $message = $generator->current();
self::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $message);
self::assertSame(__FUNCTION__, $envelope->body); self::assertSame(__FUNCTION__, $message->body);
$envelope->finish(); $message->finish();
$generator->next(); $generator->next();
self::assertNull($generator->current()); self::assertNull($generator->current());
$writer->mpub(__FUNCTION__, [ $producer->mpub(__FUNCTION__, [
'First mpub message.', 'First mpub message.',
'Second mpub message.', 'Second mpub message.',
]); ]);
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $message */
$envelope = $generator->current(); $message = $generator->current();
self::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $message);
self::assertSame('First mpub message.', $envelope->body); self::assertSame('First mpub message.', $message->body);
$envelope->finish(); $message->finish();
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $message */
$envelope = $generator->current(); $message = $generator->current();
self::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $message);
self::assertSame('Second mpub message.', $envelope->body); self::assertSame('Second mpub message.', $message->body);
$envelope->requeue(0); $message->requeue(0);
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $message */
$envelope = $generator->current(); $message = $generator->current();
self::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $message);
self::assertSame('Second mpub message.', $envelope->body); self::assertSame('Second mpub message.', $message->body);
$envelope->finish(); $message->finish();
$writer->dpub(__FUNCTION__, 2000, 'Deferred message.'); $producer->dpub(__FUNCTION__, 2000, 'Deferred message.');
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $message */
$envelope = $generator->current(); $message = $generator->current();
self::assertNull($envelope); self::assertNull($message);
$generator->send(Subscriber::CHANGE_TIMEOUT); $generator->send(Subscriber::CHANGE_TIMEOUT);
$generator->send(10.0); $generator->send(10.0);
/** @var null|Message $envelope */ /** @var null|Message $message */
$envelope = $generator->current(); $message = $generator->current();
self::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $message);
self::assertSame('Deferred message.', $envelope->body); self::assertSame('Deferred message.', $message->body);
$envelope->touch(); $message->touch();
$envelope->finish(); $message->finish();
self::assertFalse($reader->isClosed()); self::assertFalse($consumer->isClosed());
$generator->send(Subscriber::STOP); $generator->send(Subscriber::STOP);
self::assertTrue($reader->isClosed()); self::assertTrue($consumer->isClosed());
} }
/** /**
@ -86,8 +86,8 @@ final class NsqTest extends TestCase
$this->expectException(Exception::class); $this->expectException(Exception::class);
$this->expectExceptionMessage($exceptionMessage); $this->expectExceptionMessage($exceptionMessage);
$writer = new Producer('tcp://localhost:4150'); $producer = new Producer('tcp://localhost:4150');
$writer->pub($topic, $body); $producer->pub($topic, $body);
} }
/** /**