php-api-clients / rx

src/functions_include.php

Spacing +2 added lines, -2 removed lines

@@ -1,9 +1,9 @@
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace ApiClients\Tools\Rx;
 
 // @codeCoverageIgnoreStart
 if (!function_exists('ApiClients\Tools\Rx\unwrapObservableFromPromise')) {
-    require __DIR__ . '/functions.php';
+    require __DIR__.'/functions.php';
 }
 // @codeCoverageIgnoreEnd

src/functions.php

Spacing +6 added lines, -6 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace ApiClients\Tools\Rx;
 
@@ -17,19 +17,19 @@ 
 function unwrapObservableFromPromise(PromiseInterface $promise): Observable
 {
     return Observable::create(
-        function (
+        function(
             ObserverInterface $observer,
             SchedulerInterface $scheduler
         ) use ($promise) {
-            resolve($promise)->done(function (Observable $observable) use ($observer, $scheduler) {
+            resolve($promise)->done(function(Observable $observable) use ($observer, $scheduler) {
                 $observable->subscribeCallback(
-                    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();
                     }
                 );