Update tests

mateusjunges · Aug 18, 2024 · 6e154b0 · 6e154b0
1 parent f086e92
commit 6e154b0
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/tests/KafkaTest.php b/tests/KafkaTest.php
@@ -70,8 +70,7 @@ public function it_can_publish_messages_asynchronously(): void
             ->getMock();
 
         $mockedProducer = m::mock(Producer::class)
-            ->shouldReceive('newTopic')
-            ->andReturn($mockedProducerTopic)
+            ->shouldReceive('newTopic')->with('test')->twice()->andReturn($mockedProducerTopic)
             ->shouldReceive('poll')->twice()
             ->shouldReceive('flush')->once()
             ->andReturn(RD_KAFKA_RESP_ERR_NO_ERROR)