Skip to content

Commit f80ea4d

Browse files
committed
Namespaced it and turned it into a collector
1 parent 95fd95f commit f80ea4d

File tree

4 files changed

+57
-39
lines changed

4 files changed

+57
-39
lines changed

Diff for: composer.json

+3
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,9 @@
1919
"api-clients/test-utilities": "^5.1"
2020
},
2121
"autoload": {
22+
"psr-4": {
23+
"PHPDIDefinitions\\ReactInspector\\": "src/"
24+
},
2225
"files": ["etc/bootstrap.php"]
2326
},
2427
"extra": {

Diff for: composer.lock

+38-35
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Diff for: etc/di/event-loop.php

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
<?php declare(strict_types=1);
22

3+
use PHPDIDefinitions\ReactInspector\AdditionalCollectors;
34
use function EventLoop\getLoop;
45
use React\EventLoop\LoopInterface;
56
use ReactInspector\EventLoop\LoopCollector;
@@ -19,7 +20,7 @@
1920
new LoopCollector($loop),
2021
new MemoryUsageCollector($loop),
2122
new IOCollector(),
22-
...$additionalCollectors->get()
23+
$additionalCollectors
2324
);
2425
},
2526
];

Diff for: src/AdditionalCollectors.php

+14-3
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,12 @@
11
<?php
22

3+
namespace PHPDIDefinitions\ReactInspector;
4+
35
use ReactInspector\CollectorInterface;
6+
use Rx\Observable;
7+
use function ApiClients\Tools\Rx\observableFromArray;
48

5-
final class AdditionalCollectors
9+
final class AdditionalCollectors implements CollectorInterface
610
{
711
private $collectors = [];
812

@@ -11,9 +15,16 @@ public function add(CollectorInterface $collector): void
1115
$this->collectors[] = $collector;
1216
}
1317

14-
public function get(): array
18+
public function collect(): Observable
19+
{
20+
return observableFromArray($this->collectors)->map(function (CollectorInterface $collector) {
21+
return $collector->collect();
22+
});
23+
}
24+
25+
public function cancel(): void
1526
{
16-
return $this->collectors;
27+
// void
1728
}
1829
}
1930

0 commit comments

Comments
 (0)