Rx\Custom\Operator\JsonDecodeOperator

Complexity

Total Complexity

1

Size/Duplication

Total Lines	17
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

<?php
class JsonDecodeOperator implements OperatorInterface
{
    /**
     * @inheritDoc
     */
    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']
        ));
    }