SmoothPhp / CQRS-ES-Framework-Laravel

src/Console/RunProjectionCommand.php

Spacing +13 added lines, -13 removed lines

@@ -76,7 +76,7 @@ 
         $projectionRequest = collect(explode(',', $this->argument('projections')));
 
         $projectionsServiceProviders = $projectionRequest->each(
-            function ($projectionName) {
+            function($projectionName) {
                 if (!isset($this->config->get('cqrses.projections_service_providers')[$projectionName])) {
                     $this->error("{$projectionName} Does not exist, check cqrses config");
 
@@ -84,26 +84,26 @@ 
                 }
             }
         )->map(
-            function ($projectionName) {
+            function($projectionName) {
                 return $this->application->make(
                     $this->config->get('cqrses.projections_service_providers')[$projectionName]
                 );
             }
         )->each(
-            function (ProjectionServiceProvider $projectionClass) {
+            function(ProjectionServiceProvider $projectionClass) {
                 $this->downMigration($projectionClass);
             }
         )->each(
-            function (ProjectionServiceProvider $projectionClass) {
+            function(ProjectionServiceProvider $projectionClass) {
                 $this->upMigration($projectionClass);
             }
         );
 
         /** @var Collection|Subscriber[] $projections */
         $projections = $projectionsServiceProviders->map(
-            function (ProjectionServiceProvider $projectServiceProvider) {
+            function(ProjectionServiceProvider $projectServiceProvider) {
                 return collect($projectServiceProvider->getProjections())->map(
-                    function ($projection) {
+                    function($projection) {
                         return $this->application->make($projection);
                     }
                 );
@@ -111,11 +111,11 @@ 
         )->collapse();
 
         $events = $projections->map(
-            function (Subscriber $subscriber) {
+            function(Subscriber $subscriber) {
                 return array_keys($subscriber->getSubscribedEvents());
             }
         )->collapse()->map(
-            function ($eventClassName) {
+            function($eventClassName) {
                 return str_replace('\\', '.', $eventClassName);
             }
         );
@@ -129,7 +129,7 @@ 
     public function downMigration(ProjectionServiceProvider $projectionServiceProvider)
     {
         $response = $projectionServiceProvider->down();
-        $this->line($response ?? 'Migrated Down: ' . get_class($projectionServiceProvider));
+        $this->line($response ?? 'Migrated Down: '.get_class($projectionServiceProvider));
     }
 
     /**
@@ -138,7 +138,7 @@ 
     public function upMigration(ProjectionServiceProvider $projectionServiceProvider)
     {
         $response = $projectionServiceProvider->up();
-        $this->line($response ?? 'Migrated Up: ' . get_class($projectionServiceProvider));
+        $this->line($response ?? 'Migrated Up: '.get_class($projectionServiceProvider));
     }
 
     /**
@@ -150,7 +150,7 @@ 
     protected function replayEvents($projections, $events)
     {
         $eventCount = $this->eventStore->getEventCountByTypes($events);
-        $take = (int)$this->config->get('cqrses.rebuild_transaction_size', 1000);
+        $take = (int) $this->config->get('cqrses.rebuild_transaction_size', 1000);
 
         $this->output->progressStart($eventCount);
         $dispatcher = $this->buildAndRegisterDispatcher($projections);
@@ -170,7 +170,7 @@ 
         }
 
         $this->output->progressFinish();
-        $this->line((memory_get_peak_usage(true) / 1024 / 1024) . "mb Peak Usage", false);
+        $this->line((memory_get_peak_usage(true) / 1024 / 1024)."mb Peak Usage", false);
     }
 
     /**
@@ -203,7 +203,7 @@ 
         );
 
         $projections->each(
-            function ($projection) use ($dispatcher) {
+            function($projection) use ($dispatcher) {
                 $dispatcher->addSubscriber($projection);
             }
         );