ApiClients\Rx\Operator\JsonDecodeOperator::__invoke()

Complexity

Conditions	1
Paths	1

Size

Total Lines	13
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function __invoke(
        ObservableInterface $observable,
        ObserverInterface $observer,
        SchedulerInterface $scheduler = null
    ) {
        return $observable->subscribe(new CallbackObserver(
            function (string $json) use ($observer) {
                $observer->onNext(json_decode($json, true));
            },
            [$observer, 'onError'],
            [$observer, 'onCompleted']
        ));
    }
}