@@ -48,7 +48,7 @@ discard block |
||
48 | 48 | */ |
49 | 49 | public function sourcing(Telemetry $source, int $period) : void |
50 | 50 | { |
51 | - $this->tasks[$this->insert($period, function (string $ik) { |
|
51 | + $this->tasks[$this->insert($period, function(string $ik) { |
|
52 | 52 | $this->running($ik); |
53 | 53 | })][] = $source; |
54 | 54 | |
@@ -74,7 +74,7 @@ discard block |
||
74 | 74 | */ |
75 | 75 | public function stopping() : void |
76 | 76 | { |
77 | - $this->clearing(function (string $ik) { |
|
77 | + $this->clearing(function(string $ik) { |
|
78 | 78 | unset($this->tasks[$ik]); |
79 | 79 | }); |
80 | 80 | } |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | private function running(string $ik) : void |
86 | 86 | { |
87 | 87 | $w = $this->tasks[$ik] ?? []; |
88 | - array_walk($w, function (Telemetry $source) { |
|
88 | + array_walk($w, function(Telemetry $source) { |
|
89 | 89 | $this->gathering($source); |
90 | 90 | }); |
91 | 91 | } |
@@ -59,10 +59,10 @@ |
||
59 | 59 | */ |
60 | 60 | public function start() : self |
61 | 61 | { |
62 | - $this->timer = Timer::loop($this->cycled * 1000, function () { |
|
62 | + $this->timer = Timer::loop($this->cycled * 1000, function() { |
|
63 | 63 | $metrics = []; |
64 | 64 | |
65 | - $this->source->spouting(static function ( |
|
65 | + $this->source->spouting(static function( |
|
66 | 66 | string $typed, |
67 | 67 | string $named, |
68 | 68 | string $grouped, |