@@ -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->subscribe( |
| 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 | ); |