php-api-clients / rx-operators

src/JsonDecodeOperator.php

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace ApiClients\Rx\Operator;
 
@@ -19,7 +19,7 @@ 
         SchedulerInterface $scheduler = null
     ) {
         return $observable->subscribe(new CallbackObserver(
-            function (string $json) use ($observer) {
+            function(string $json) use ($observer) {
                 $observer->onNext(json_decode($json, true));
             },
             [$observer, 'onError'],

src/JsonEncodeOperator.php

Spacing +2 added lines, -2 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 
 namespace ApiClients\Rx\Operator;
 
@@ -19,7 +19,7 @@ 
         SchedulerInterface $scheduler = null
     ) {
         return $observable->subscribe(new CallbackObserver(
-            function (array $json) use ($observer) {
+            function(array $json) use ($observer) {
                 $observer->onNext(json_encode($json));
             },
             [$observer, 'onError'],