Fix styling

mateusjunges · Nov 29, 2021 · 340b675 · 340b675
1 parent 015cc17
commit 340b675
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/Consumers/Consumer.php b/src/Consumers/Consumer.php
@@ -2,6 +2,7 @@
 
 namespace Junges\Kafka\Consumers;
 
+use Closure;
 use Junges\Kafka\Commit\CommitterFactory;
 use Junges\Kafka\Commit\Contracts\Committer;
 use Junges\Kafka\Commit\NativeSleeper;
@@ -18,7 +19,6 @@
 use RdKafka\Message;
 use RdKafka\Producer as KafkaProducer;
 use Throwable;
-use Closure;
 
 class Consumer
 {

diff --git a/tests/Consumers/ConsumerTest.php b/tests/Consumers/ConsumerTest.php
@@ -125,9 +125,9 @@ public function testCanStopConsume()
         $this->mockProducer();
 
         $this->stoppableConsumer = Kafka::createConsumer(['test'])
-            ->withHandler(function(KafkaConsumerMessage $message) {
+            ->withHandler(function (KafkaConsumerMessage $message) {
                 if ($message->getKey() === 'key2' && $this->stoppableConsumer) {
-                    $this->stoppableConsumer->stopConsume(function() {
+                    $this->stoppableConsumer->stopConsume(function () {
                         $this->stoppableConsumerStopped = true;
                     });
                 }

diff --git a/tests/LaravelKafkaTestCase.php b/tests/LaravelKafkaTestCase.php
@@ -92,7 +92,7 @@ protected function mockConsumerWithMessage(Message ...$message)
             ->andReturn(m::self())
             ->shouldReceive('consume')
             ->withAnyArgs()
-            ->andReturnUsing(function() use (&$message) {
+            ->andReturnUsing(function () use (&$message) {
                 return array_splice($message, 0, 1)[0] ?? null;
             })
             ->shouldReceive('commit')