We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0239c53 commit 419f1ffCopy full SHA for 419f1ff
test/QueueTest.php
@@ -544,7 +544,9 @@ public function testBufferSize(int $bufferSize): void
544
self::assertTrue($pipeline->continue());
545
self::assertTrue($blocked->isComplete());
546
547
- self::assertFalse($source->pushAsync('x')->isComplete());
+ $blocked = $source->pushAsync('x');
548
+ self::assertFalse($blocked->isComplete());
549
+ $blocked->ignore();
550
551
if ($bufferSize === 0) {
552
return;
0 commit comments