From 54945b7655503817492ce915f7ac872a7e75a68c Mon Sep 17 00:00:00 2001
From: dmitry krokhin <nekufa@gmail.com>
Date: Mon, 23 Dec 2024 11:54:36 +0300
Subject: [PATCH] add tests

---
 tests/Functional/StreamTest.php | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/Functional/StreamTest.php b/tests/Functional/StreamTest.php
index e514af2..0d06d1e 100644
--- 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);
     }