@@ -5,7 +5,6 @@ |
||
| 5 | 5 | use React\Promise\PromiseInterface; |
| 6 | 6 | use Rx\Observable; |
| 7 | 7 | use Rx\ObserverInterface; |
| 8 | -use Rx\SchedulerInterface; |
|
| 9 | 8 | use function React\Promise\resolve; |
| 10 | 9 | |
| 11 | 10 | /** |
@@ -1,4 +1,4 @@ discard block |
||
| 1 | -<?php declare(strict_types=1); |
|
| 1 | +<?php declare(strict_types = 1); |
|
| 2 | 2 | |
| 3 | 3 | namespace ApiClients\Tools\Rx; |
| 4 | 4 | |
@@ -17,18 +17,18 @@ discard block |
||
| 17 | 17 | function unwrapObservableFromPromise(PromiseInterface $promise): Observable |
| 18 | 18 | { |
| 19 | 19 | return Observable::create( |
| 20 | - function ( |
|
| 20 | + function( |
|
| 21 | 21 | ObserverInterface $observer |
| 22 | 22 | ) use ($promise) { |
| 23 | - resolve($promise)->done(function (Observable $observable) use ($observer) { |
|
| 23 | + resolve($promise)->done(function(Observable $observable) use ($observer) { |
|
| 24 | 24 | $observable->subscribeCallback( |
| 25 | - function ($next) use ($observer) { |
|
| 25 | + function($next) use ($observer) { |
|
| 26 | 26 | $observer->onNext($next); |
| 27 | 27 | }, |
| 28 | - function ($error) use ($observer) { |
|
| 28 | + function($error) use ($observer) { |
|
| 29 | 29 | $observer->onError($error); |
| 30 | 30 | }, |
| 31 | - function () use ($observer) { |
|
| 31 | + function() use ($observer) { |
|
| 32 | 32 | $observer->onCompleted(); |
| 33 | 33 | } |
| 34 | 34 | ); |
@@ -1,7 +1,7 @@ |
||
| 1 | -<?php declare(strict_types=1); |
|
| 1 | +<?php declare(strict_types = 1); |
|
| 2 | 2 | |
| 3 | 3 | use Rx\Scheduler; |
| 4 | 4 | |
| 5 | -Scheduler::setDefaultFactory(function () { |
|
| 5 | +Scheduler::setDefaultFactory(function() { |
|
| 6 | 6 | return new Scheduler\ImmediateScheduler(); |
| 7 | 7 | }); |