@@ -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, |