add tests for commit without ack

Author: rekby

tests/topics/test_topic_reader.py

@@ -31,7 +31,18 @@ async def test_read_message(
 
         await reader.close()
 
-    async def test_read_and_commit_message(
+    async def test_read_and_commit_with_close_reader(
+        self, driver, topic_path, topic_with_messages, topic_consumer
+    ):
+        async with driver.topic_client.reader(topic_path, topic_consumer) as reader:
+            message = await reader.receive_message()
+            reader.commit(message)
+
+        async with driver.topic_client.reader(topic_path, topic_consumer) as reader:
+            message2 = await reader.receive_message()
+            assert message != message2
+
+    async def test_read_and_commit_with_ack(
         self, driver, topic_path, topic_with_messages, topic_consumer
     ):
 
@@ -103,7 +114,18 @@ def test_read_message(
 
         reader.close()
 
-    def test_read_and_commit_message(
+    def test_read_and_commit_with_close_reader(
+        self, driver_sync, topic_path, topic_with_messages, topic_consumer
+    ):
+        with driver_sync.topic_client.reader(topic_path, topic_consumer) as reader:
+            message = reader.receive_message()
+            reader.commit(message)
+
+        with driver_sync.topic_client.reader(topic_path, topic_consumer) as reader:
+            message2 = reader.receive_message()
+            assert message != message2
+
+    def test_read_and_commit_with_ack(
         self, driver_sync, topic_path, topic_with_messages, topic_consumer
     ):
         reader = driver_sync.topic_client.reader(topic_path, topic_consumer)