Ignore failed push in test

amphp · Nov 18, 2022 · 419f1ff · 419f1ff
1 parent 0239c53
commit 419f1ff
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/test/QueueTest.php b/test/QueueTest.php
@@ -544,7 +544,9 @@ public function testBufferSize(int $bufferSize): void
         self::assertTrue($pipeline->continue());
         self::assertTrue($blocked->isComplete());
 
-        self::assertFalse($source->pushAsync('x')->isComplete());
+        $blocked = $source->pushAsync('x');
+        self::assertFalse($blocked->isComplete());
+        $blocked->ignore();
 
         if ($bufferSize === 0) {
             return;