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

cs: php_unit_test_case_static_method_calls with call_type self

Browse Source
This commit is contained in:
Konstantin Grachev
2021-01-23 01:31:42 +03:00
parent 18ecca3c40
commit bf738254b1
2 changed files with 17 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
.php_cs.dist
View File

@ -12,6 +12,7 @@ return (new PhpCsFixer\Config())
'php_unit_internal_class' => false, 'php_unit_internal_class' => false,
'php_unit_test_class_requires_covers' => false, 'php_unit_test_class_requires_covers' => false,
'yoda_style' => true, 'yoda_style' => true,
'php_unit_test_case_static_method_calls'=> ['call_type' => 'self'],
]) ])
->setFinder( ->setFinder(
PhpCsFixer\Finder::create() PhpCsFixer\Finder::create()

31
tests/NsqTest.php
View File

@ -3,6 +3,7 @@
declare(strict_types=1); declare(strict_types=1);
use Nsq\Message; use Nsq\Message;
use Nsq\Reader;
use Nsq\Subscriber; use Nsq\Subscriber;
use Nsq\Writer; use Nsq\Writer;
use Nsq\Exception; use Nsq\Exception;
@ -15,19 +16,19 @@ final class NsqTest extends TestCase
$writer = new Writer('tcp://localhost:4150'); $writer = new Writer('tcp://localhost:4150');
$writer->pub(__FUNCTION__, __FUNCTION__); $writer->pub(__FUNCTION__, __FUNCTION__);
$reader = new \Nsq\Reader('tcp://localhost:4150'); $reader = new Reader('tcp://localhost:4150');
$subscriber = new Subscriber($reader); $subscriber = new Subscriber($reader);
$generator = $subscriber->subscribe(__FUNCTION__, __FUNCTION__, 1); $generator = $subscriber->subscribe(__FUNCTION__, __FUNCTION__, 1);
/** @var null|Message $envelope */ /** @var null|Message $envelope */
$envelope = $generator->current(); $envelope = $generator->current();
static::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $envelope);
static::assertSame(__FUNCTION__, $envelope->body); self::assertSame(__FUNCTION__, $envelope->body);
$envelope->finish(); $envelope->finish();
$generator->next(); $generator->next();
static::assertNull($generator->current()); self::assertNull($generator->current());
$writer->mpub(__FUNCTION__, [ $writer->mpub(__FUNCTION__, [
'First mpub message.', 'First mpub message.',
@ -37,22 +38,22 @@ final class NsqTest extends TestCase
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $envelope */
$envelope = $generator->current(); $envelope = $generator->current();
static::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $envelope);
static::assertSame('First mpub message.', $envelope->body); self::assertSame('First mpub message.', $envelope->body);
$envelope->finish(); $envelope->finish();
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $envelope */
$envelope = $generator->current(); $envelope = $generator->current();
static::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $envelope);
static::assertSame('Second mpub message.', $envelope->body); self::assertSame('Second mpub message.', $envelope->body);
$envelope->requeue(0); $envelope->requeue(0);
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $envelope */
$envelope = $generator->current(); $envelope = $generator->current();
static::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $envelope);
static::assertSame('Second mpub message.', $envelope->body); self::assertSame('Second mpub message.', $envelope->body);
$envelope->finish(); $envelope->finish();
$writer->dpub(__FUNCTION__, 2000, 'Deferred message.'); $writer->dpub(__FUNCTION__, 2000, 'Deferred message.');
@ -60,20 +61,20 @@ final class NsqTest extends TestCase
$generator->next(); $generator->next();
/** @var null|Message $envelope */ /** @var null|Message $envelope */
$envelope = $generator->current(); $envelope = $generator->current();
static::assertNull($envelope); self::assertNull($envelope);
$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 $envelope */
$envelope = $generator->current(); $envelope = $generator->current();
static::assertInstanceOf(Message::class, $envelope); self::assertInstanceOf(Message::class, $envelope);
static::assertSame('Deferred message.', $envelope->body); self::assertSame('Deferred message.', $envelope->body);
$envelope->finish(); $envelope->finish();
static::assertFalse($reader->isClosed()); self::assertFalse($reader->isClosed());
$generator->send(Subscriber::STOP); $generator->send(Subscriber::STOP);
static::assertTrue($reader->isClosed()); self::assertTrue($reader->isClosed());
} }
/** /**