php-api-clients / rx-operators

src/JsonDecodeOperator.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
         ObserverInterface $observer
     ): DisposableInterface {
         return $observable->subscribe(
-            function (string $json) use ($observer): void {
+            function(string $json) use ($observer): void {
                 $observer->onNext(\json_decode($json, true));
             },
             [$observer, 'onError'],

src/JsonEncodeOperator.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
         ObserverInterface $observer
     ): DisposableInterface {
         return $observable->subscribe(
-            function (array $json) use ($observer): void {
+            function(array $json) use ($observer): void {
                 $observer->onNext(\json_encode($json));
             },
             [$observer, 'onError'],