add tests

basis-company · Dec 23, 2024 · 54945b7 · 54945b7
1 parent 4318acc
commit 54945b7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/tests/Functional/StreamTest.php b/tests/Functional/StreamTest.php
@@ -174,7 +174,8 @@ public function testDeduplication()
             ->setSubjects(['tester'])
             ->setDuplicateWindow(0.5); // 500ms windows duplicate
 
-        $stream->create();
+        $stream->createIfNotExists();
+        $stream->createIfNotExists(); // should not provide an error
 
         // windows value using nanoseconds
         $this->assertEquals(0.5 * 1_000_000_000, $stream->info()->getValue('config.duplicate_window'));
@@ -285,6 +286,7 @@ public function testNoMessages()
                 $this->empty = true;
             });
 
+        $this->assertSame($consumer->getDelay(), 0);
         $this->assertFalse($this->called);
         $this->assertTrue($this->empty);
     }