fix: Implement publishAsync on KafkaFake (#340)

* fix: Implement publishAsync on KafkaFake

* chore: add tests

Author: hauke-d

src/Support/Testing/Fakes/KafkaFake.php

@@ -34,6 +34,11 @@ public function publish(?string $broker = null): ProducerBuilderFake
         return $this->makeProducerBuilderFake($broker);
     }
 
+    public function asyncPublish(?string $broker = null): ProducerBuilderFake
+    {
+        return $this->publish($broker);
+    }
+
     /** Return a ConsumerBuilder instance. */
     public function consumer(array $topics = [], string $groupId = null, string $brokers = null): BuilderFake
     {

tests/KafkaFakeTest.php

@@ -40,6 +40,30 @@ public function testItStorePublishedMessagesOnArray(): void
         $this->fake->assertPublished($producer->getMessage());
     }
 
+    public function testItStoresMultipleMessages(): void
+    {
+        for ($i = 0; $i < 3; $i++) {
+            $this->fake->publish()
+                ->onTopic('topic')
+                ->withBody('test')
+                ->send();
+        }
+
+        $this->fake->assertPublishedTimes(3);
+    }
+
+    public function testItStoresMultipleMessagesWhenPublishingAsync(): void
+    {
+        for ($i = 0; $i < 3; $i++) {
+            $this->fake->asyncPublish()
+                ->onTopic('topic')
+                ->withBody('test')
+                ->send();
+        }
+
+        $this->fake->assertPublishedTimes(3);
+    }
+
     public function testAssertPublished(): void
     {
         try {