php-api-clients / rx

src/functions.php

Spacing +7 added lines, -7 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace ApiClients\Tools\Rx;
 
@@ -20,18 +20,18 @@ 
 function unwrapObservableFromPromise(PromiseInterface $promise): Observable
 {
     return Observable::create(
-        function (
+        function(
             ObserverInterface $observer
         ) use ($promise) {
-            resolve($promise)->done(function (Observable $observable) use ($observer) {
+            resolve($promise)->done(function(Observable $observable) use ($observer) {
                 $observable->subscribe(
-                    function ($next) use ($observer) {
+                    function($next) use ($observer) {
                         $observer->onNext($next);
                     },
-                    function ($error) use ($observer) {
+                    function($error) use ($observer) {
                         $observer->onError($error);
                     },
-                    function () use ($observer) {
+                    function() use ($observer) {
                         $observer->onCompleted();
                     }
                 );
@@ -58,7 +58,7 @@ 
 function setAsyncScheduler(LoopInterface $loop)
 {
     try {
-        Scheduler::setAsyncFactory(function () use ($loop) {
+        Scheduler::setAsyncFactory(function() use ($loop) {
             return new Scheduler\EventLoopScheduler($loop);
         });
     } catch (Exception $e) {