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/bootstrap.php

Spacing +2 added lines, -2 removed lines

@@ -1,7 +1,7 @@
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 use Rx\Scheduler;
 
-Scheduler::setDefaultFactory(function () {
+Scheduler::setDefaultFactory(function() {
     return new Scheduler\ImmediateScheduler();
 });

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) {