KVStore::watching() - Code Metrics - carno-php/consul - Measure and Improve Code Quality continuously with Scrutinizer

KVStore::watching() A
last analyzed 2019-06-20 01:55 UTC

↳ Parent: KVStore

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	6
dl	0
loc	13
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	3

<?php
/**
 * KVStore reader
 * User: moyo
 * Date: 13/10/2017
 * Time: 5:45 PM
 */

namespace Carno\Consul;

use Carno\Channel\Chan;
use Carno\Consul\APIs\KVGetting;
use Carno\Consul\Chips\AgentRequired;
use Carno\Consul\Chips\GWatcher;
use Carno\Consul\Chips\WValues;

class KVStore
{
    use AgentRequired, WValues, GWatcher;

    /**
     * keys=* means all keys in folder
     * keys=abc means keys prefix with "abc"
     * @param string $folder
     * @param string $keys
     * @param Chan $notify
     */
    public function watching(string $folder, string $keys, Chan $notify) : void
    {
        $path = $keys === '*' ? $folder : sprintf('%s/%s', $folder, $keys);

        $ig = function () use ($path) {
            return (new KVGetting($this->agent))->path($path);
        };

        $do = function (KVGetting $lister) use ($notify) {
            yield $notify->send($this->changed(yield $lister->result()));
        };

        $this->nwProcess($notify->closed(), $ig, $do, 'KVStore watcher interrupted', ['path' => $path]);
    }
}


1			<?php
2			/**
3			* KVStore reader
4			* User: moyo
5			* Date: 13/10/2017
6			* Time: 5:45 PM
7			*/
8
9			namespace Carno\Consul;
10
11			use Carno\Channel\Chan;
12			use Carno\Consul\APIs\KVGetting;
13			use Carno\Consul\Chips\AgentRequired;
14			use Carno\Consul\Chips\GWatcher;
15			use Carno\Consul\Chips\WValues;
16
17			class KVStore
18			{
19			use AgentRequired, WValues, GWatcher;
20
21			/**
22			* keys=* means all keys in folder
23			* keys=abc means keys prefix with "abc"
24			* @param string $folder
25			* @param string $keys
26			* @param Chan $notify
27			*/
28			public function watching(string $folder, string $keys, Chan $notify) : void
29			{
30			$path = $keys === '*' ? $folder : sprintf('%s/%s', $folder, $keys);
31
32			$ig = function () use ($path) {
33			return (new KVGetting($this->agent))->path($path);
34			};
35
36			$do = function (KVGetting $lister) use ($notify) {
37			yield $notify->send($this->changed(yield $lister->result()));
38			};
39
40			$this->nwProcess($notify->closed(), $ig, $do, 'KVStore watcher interrupted', ['path' => $path]);
41			}
42			}
43

carno-php / consul

KVStore::watching() A last analyzed 2019-06-20 01:55 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

KVStore::watching() A
last analyzed 2019-06-20 01:55 UTC