Revert "Revert metrics in a thread"

MammatusPHP · Mar 21, 2021 · 6bd4bc8 · 6bd4bc8
1 parent e786307
commit 6bd4bc8
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 6 deletions.
diff --git a/etc/di/metrics-registry.php b/etc/di/metrics-registry.php
@@ -1,9 +1,9 @@
 <?php declare(strict_types=1);
 
-use WyriHaximus\Metrics\Configuration;
-use WyriHaximus\Metrics\InMemory\Registry as InMemoryRegistry;
+use WyriHaximus\Metrics\LazyRegistry\Registry as LazyRegistry;
 use WyriHaximus\Metrics\Registry;
 
 return [
-    Registry::class => new InMemoryRegistry(Configuration::create()),
+    LazyRegistry::class => new LazyRegistry(),
+    Registry::class => static fn (LazyRegistry $registry) => $registry,
 ];
diff --git a/etc/di/object-proxy.php b/etc/di/object-proxy.php
@@ -6,13 +6,16 @@
 use ReactParallel\ObjectProxy\Proxy;
 use ReactParallel\ObjectProxy\ProxyListInterface;
 use WyriHaximus\Metrics\Registry;
+use WyriHaximus\Metrics\Configuration as MetricsConfiguration;
+use WyriHaximus\Metrics\LazyRegistry\Registry as LazyRegistry;
+use WyriHaximus\Metrics\InMemory\Registry as InMemoryRegistry;
 
 return [
     ProxyListInterface::class => static fn (): ProxyListInterface => new ProxyList(),
-    Configuration::class => static fn (Factory $factory, Registry $registry, ProxyListInterface $proxyList): Configuration => (new Configuration($factory))->withProxyList($proxyList)->withMetrics(Configuration\Metrics::create($registry)),
-    Proxy::class => static function (Configuration $configuration, Registry $registry) {
+    Configuration::class => static fn (Factory $factory, LazyRegistry $registry, ProxyListInterface $proxyList): Configuration => (new Configuration($factory))->withProxyList($proxyList)->withMetrics(Configuration\Metrics::create($registry)),
+    Proxy::class => static function (Configuration $configuration, LazyRegistry $registry) {
         $proxy = new Proxy($configuration);
-        $proxy->share($registry, Registry::class);
+        $registry->register($proxy->thread(new InMemoryRegistry(MetricsConfiguration::create()), Registry::class));
 
         return $proxy;
     },