Code Duplication - php-api-clients/rx-operators - Measure and Improve Code Quality continuously with Scrutinizer

rx-operators

Code Duplication Length = 18-18 lines in 2 locations

src/JsonDecodeOperator.php 1 location


use Rx\ObserverInterface;
use Rx\Operator\OperatorInterface;

final class JsonDecodeOperator implements OperatorInterface
{
    /**
     * @inheritDoc
     */
    public function __invoke(
        ObservableInterface $observable,
        ObserverInterface $observer
    ): DisposableInterface {
        return $observable->subscribe(
            function (string $json) use ($observer): void {
                $observer->onNext(\json_decode($json, true));
            },
            [$observer, 'onError'],
            [$observer, 'onCompleted']
        );
    }
}


src/JsonEncodeOperator.php 1 location


use Rx\ObserverInterface;
use Rx\Operator\OperatorInterface;

final class JsonEncodeOperator implements OperatorInterface
{
    /**
     * @inheritDoc
     */
    public function __invoke(
        ObservableInterface $observable,
        ObserverInterface $observer
    ): DisposableInterface {
        return $observable->subscribe(
            function (array $json) use ($observer): void {
                $observer->onNext(\json_encode($json));
            },
            [$observer, 'onError'],
            [$observer, 'onCompleted']
        );
    }
}


		@@ 10-27 (lines=18) @@
7		use Rx\ObserverInterface;
8		use Rx\Operator\OperatorInterface;
9
10		final class JsonDecodeOperator implements OperatorInterface
11		{
12		/**
13		* @inheritDoc
14		*/
15		public function __invoke(
16		ObservableInterface $observable,
17		ObserverInterface $observer
18		): DisposableInterface {
19		return $observable->subscribe(
20		function (string $json) use ($observer): void {
21		$observer->onNext(\json_decode($json, true));
22		},
23		[$observer, 'onError'],
24		[$observer, 'onCompleted']
25		);
26		}
27		}
28

		@@ 10-27 (lines=18) @@
7		use Rx\ObserverInterface;
8		use Rx\Operator\OperatorInterface;
9
10		final class JsonEncodeOperator implements OperatorInterface
11		{
12		/**
13		* @inheritDoc
14		*/
15		public function __invoke(
16		ObservableInterface $observable,
17		ObserverInterface $observer
18		): DisposableInterface {
19		return $observable->subscribe(
20		function (array $json) use ($observer): void {
21		$observer->onNext(\json_encode($json));
22		},
23		[$observer, 'onError'],
24		[$observer, 'onCompleted']
25		);
26		}
27		}
28

php-api-clients / rx-operators

GitHub Access Token became invalid

Code Duplication Length = 18-18 lines in 2 locations

src/JsonDecodeOperator.php 1 location

src/JsonEncodeOperator.php 1 location