@@ -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 | }); |